test_class.declarator: config = new Config()
test_class.modifier: private static final
test_class.original_string: private static final Config config = new Config();
test_class.type: Config
test_class.var_name: config
test_class.declarator: topology
test_class.modifier: private
test_class.original_string: private StormTopology topology;
test_class.type: StormTopology
test_class.var_name: topology
test_class.file: storm/storm-benchmark/src/test/java/storm/benchmark/metrics/BasicMetricsCollectorTest.java
test_class.identifier: BasicMetricsCollectorTest
test_case.body: @Test(dataProvider = "getSpoutLatencyMetrics")
    public void testCollectSpoutLatency(Set<MetricsItem> items, boolean expected) {
      BasicMetricsCollector collector = new BasicMetricsCollector(config, topology, items);
      assertThat(collector.collectSpoutLatency).isEqualTo(expected);
    }
test_case.class_method_signature: BasicMetricsCollectorTest.testCollectSpoutLatency(Set<MetricsItem> items, boolean expected)
test_case.full_signature: @Test(dataProvider = "getSpoutLatencyMetrics") public void testCollectSpoutLatency(Set<MetricsItem> items, boolean expected)
test_case.identifier: testCollectSpoutLatency
test_case.invocations: isEqualTo assertThat
test_case.modifiers: @Test(dataProvider = "getSpoutLatencyMetrics") public
test_case.parameters: (Set<MetricsItem> items, boolean expected)
test_case.return: void
test_case.signature: void testCollectSpoutLatency(Set<MetricsItem> items, boolean expected)
focal_class.declarator: LOG = Logger.getLogger(BasicMetricsCollector.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = Logger.getLogger(BasicMetricsCollector.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: TIME = "time(s)"
focal_class.modifier: public static final
focal_class.original_string: public static final String TIME = "time(s)";
focal_class.type: String
focal_class.var_name: TIME
focal_class.declarator: TIME_FORMAT = "%d"
focal_class.modifier: public static final
focal_class.original_string: public static final String TIME_FORMAT = "%d";
focal_class.type: String
focal_class.var_name: TIME_FORMAT
focal_class.declarator: TOTAL_SLOTS = "total_slots"
focal_class.modifier: public static final
focal_class.original_string: public static final String TOTAL_SLOTS = "total_slots";
focal_class.type: String
focal_class.var_name: TOTAL_SLOTS
focal_class.declarator: USED_SLOTS = "used_slots"
focal_class.modifier: public static final
focal_class.original_string: public static final String USED_SLOTS = "used_slots";
focal_class.type: String
focal_class.var_name: USED_SLOTS
focal_class.declarator: WORKERS = "workers"
focal_class.modifier: public static final
focal_class.original_string: public static final String WORKERS = "workers";
focal_class.type: String
focal_class.var_name: WORKERS
focal_class.declarator: TASKS = "tasks"
focal_class.modifier: public static final
focal_class.original_string: public static final String TASKS = "tasks";
focal_class.type: String
focal_class.var_name: TASKS
focal_class.declarator: EXECUTORS = "executors"
focal_class.modifier: public static final
focal_class.original_string: public static final String EXECUTORS = "executors";
focal_class.type: String
focal_class.var_name: EXECUTORS
focal_class.declarator: TRANSFERRED = "transferred (messages)"
focal_class.modifier: public static final
focal_class.original_string: public static final String TRANSFERRED = "transferred (messages)";
focal_class.type: String
focal_class.var_name: TRANSFERRED
focal_class.declarator: THROUGHPUT = "throughput (messages/s)"
focal_class.modifier: public static final
focal_class.original_string: public static final String THROUGHPUT = "throughput (messages/s)";
focal_class.type: String
focal_class.var_name: THROUGHPUT
focal_class.declarator: THROUGHPUT_MB = "throughput (MB/s)"
focal_class.modifier: public static final
focal_class.original_string: public static final String THROUGHPUT_MB = "throughput (MB/s)";
focal_class.type: String
focal_class.var_name: THROUGHPUT_MB
focal_class.declarator: THROUGHPUT_MB_FORMAT = "%.1f"
focal_class.modifier: public static final
focal_class.original_string: public static final String THROUGHPUT_MB_FORMAT = "%.1f";
focal_class.type: String
focal_class.var_name: THROUGHPUT_MB_FORMAT
focal_class.declarator: SPOUT_EXECUTORS = "spout_executors"
focal_class.modifier: public static final
focal_class.original_string: public static final String SPOUT_EXECUTORS = "spout_executors";
focal_class.type: String
focal_class.var_name: SPOUT_EXECUTORS
focal_class.declarator: SPOUT_TRANSFERRED = "spout_transferred (messages)"
focal_class.modifier: public static final
focal_class.original_string: public static final String SPOUT_TRANSFERRED = "spout_transferred (messages)";
focal_class.type: String
focal_class.var_name: SPOUT_TRANSFERRED
focal_class.declarator: SPOUT_ACKED = "spout_acked (messages)"
focal_class.modifier: public static final
focal_class.original_string: public static final String SPOUT_ACKED = "spout_acked (messages)";
focal_class.type: String
focal_class.var_name: SPOUT_ACKED
focal_class.declarator: SPOUT_THROUGHPUT = "spout_throughput (messages/s)"
focal_class.modifier: public static final
focal_class.original_string: public static final String SPOUT_THROUGHPUT = "spout_throughput (messages/s)";
focal_class.type: String
focal_class.var_name: SPOUT_THROUGHPUT
focal_class.declarator: SPOUT_THROUGHPUT_MB = "spout_throughput (MB/s)"
focal_class.modifier: public static final
focal_class.original_string: public static final String SPOUT_THROUGHPUT_MB = "spout_throughput (MB/s)";
focal_class.type: String
focal_class.var_name: SPOUT_THROUGHPUT_MB
focal_class.declarator: SPOUT_THROUGHPUT_MB_FORMAT = "%.3f"
focal_class.modifier: public static final
focal_class.original_string: public static final String SPOUT_THROUGHPUT_MB_FORMAT = "%.3f";
focal_class.type: String
focal_class.var_name: SPOUT_THROUGHPUT_MB_FORMAT
focal_class.declarator: SPOUT_AVG_COMPLETE_LATENCY = "spout_avg_complete_latency(ms)"
focal_class.modifier: public static final
focal_class.original_string: public static final String SPOUT_AVG_COMPLETE_LATENCY = "spout_avg_complete_latency(ms)";
focal_class.type: String
focal_class.var_name: SPOUT_AVG_COMPLETE_LATENCY
focal_class.declarator: SPOUT_AVG_LATENCY_FORMAT = "%.1f"
focal_class.modifier: public static final
focal_class.original_string: public static final String SPOUT_AVG_LATENCY_FORMAT = "%.1f";
focal_class.type: String
focal_class.var_name: SPOUT_AVG_LATENCY_FORMAT
focal_class.declarator: SPOUT_MAX_COMPLETE_LATENCY = "spout_max_complete_latency(ms)"
focal_class.modifier: public static final
focal_class.original_string: public static final String SPOUT_MAX_COMPLETE_LATENCY = "spout_max_complete_latency(ms)";
focal_class.type: String
focal_class.var_name: SPOUT_MAX_COMPLETE_LATENCY
focal_class.declarator: SPOUT_MAX_LATENCY_FORMAT = "%.1f"
focal_class.modifier: public static final
focal_class.original_string: public static final String SPOUT_MAX_LATENCY_FORMAT = "%.1f";
focal_class.type: String
focal_class.var_name: SPOUT_MAX_LATENCY_FORMAT
focal_class.declarator: ALL_TIME = ":all-time"
focal_class.modifier: public static final
focal_class.original_string: public static final String ALL_TIME = ":all-time";
focal_class.type: String
focal_class.var_name: ALL_TIME
focal_class.declarator: LAST_TEN_MINS = "600"
focal_class.modifier: public static final
focal_class.original_string: public static final String LAST_TEN_MINS = "600";
focal_class.type: String
focal_class.var_name: LAST_TEN_MINS
focal_class.declarator: LAST_THREE_HOURS = "10800"
focal_class.modifier: public static final
focal_class.original_string: public static final String LAST_THREE_HOURS = "10800";
focal_class.type: String
focal_class.var_name: LAST_THREE_HOURS
focal_class.declarator: LAST_DAY = "86400"
focal_class.modifier: public static final
focal_class.original_string: public static final String LAST_DAY = "86400";
focal_class.type: String
focal_class.var_name: LAST_DAY
focal_class.declarator: config
focal_class.modifier: final
focal_class.original_string: final MetricsCollectorConfig config;
focal_class.type: MetricsCollectorConfig
focal_class.var_name: config
focal_class.declarator: topology
focal_class.modifier: final
focal_class.original_string: final StormTopology topology;
focal_class.type: StormTopology
focal_class.var_name: topology
focal_class.declarator: header = new LinkedHashSet<String>()
focal_class.modifier: final
focal_class.original_string: final Set<String> header = new LinkedHashSet<String>();
focal_class.type: Set<String>
focal_class.var_name: header
focal_class.declarator: metrics = new HashMap<String, String>()
focal_class.modifier: final
focal_class.original_string: final Map<String, String> metrics = new HashMap<String, String>();
focal_class.type: Map<String, String>
focal_class.var_name: metrics
focal_class.declarator: msgSize
focal_class.modifier: final
focal_class.original_string: final int msgSize;
focal_class.type: int
focal_class.var_name: msgSize
focal_class.declarator: collectSupervisorStats
focal_class.modifier: final
focal_class.original_string: final boolean collectSupervisorStats;
focal_class.type: boolean
focal_class.var_name: collectSupervisorStats
focal_class.declarator: collectTopologyStats
focal_class.modifier: final
focal_class.original_string: final boolean collectTopologyStats;
focal_class.type: boolean
focal_class.var_name: collectTopologyStats
focal_class.declarator: collectExecutorStats
focal_class.modifier: final
focal_class.original_string: final boolean collectExecutorStats;
focal_class.type: boolean
focal_class.var_name: collectExecutorStats
focal_class.declarator: collectThroughput
focal_class.modifier: final
focal_class.original_string: final boolean collectThroughput;
focal_class.type: boolean
focal_class.var_name: collectThroughput
focal_class.declarator: collectThroughputMB
focal_class.modifier: final
focal_class.original_string: final boolean collectThroughputMB;
focal_class.type: boolean
focal_class.var_name: collectThroughputMB
focal_class.declarator: collectSpoutThroughput
focal_class.modifier: final
focal_class.original_string: final boolean collectSpoutThroughput;
focal_class.type: boolean
focal_class.var_name: collectSpoutThroughput
focal_class.declarator: collectSpoutLatency
focal_class.modifier: final
focal_class.original_string: final boolean collectSpoutLatency;
focal_class.type: boolean
focal_class.var_name: collectSpoutLatency
focal_class.file: storm/storm-benchmark/src/main/java/storm/benchmark/metrics/BasicMetricsCollector.java
focal_class.identifier: BasicMetricsCollector
focal_class.interfaces: implements IMetricsCollector
focal_class.class_method_signature: BasicMetricsCollector.BasicMetricsCollector(Config stormConfig, StormTopology topology, Set<MetricsItem> items)
focal_class.full_signature: public  BasicMetricsCollector(Config stormConfig, StormTopology topology, Set<MetricsItem> items)
focal_class.identifier: BasicMetricsCollector
focal_class.modifiers: public
focal_class.parameters: (Config stormConfig, StormTopology topology, Set<MetricsItem> items)
focal_class.signature:  BasicMetricsCollector(Config stormConfig, StormTopology topology, Set<MetricsItem> items)
focal_class.class_method_signature: BasicMetricsCollector.run()
focal_class.full_signature: @Override public void run()
focal_class.identifier: run
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void run()
focal_class.class_method_signature: BasicMetricsCollector.getNimbusClient(Config stormConfig)
focal_class.full_signature: public Nimbus.Client getNimbusClient(Config stormConfig)
focal_class.identifier: getNimbusClient
focal_class.modifiers: public
focal_class.parameters: (Config stormConfig)
focal_class.return: Nimbus.Client
focal_class.signature: Nimbus.Client getNimbusClient(Config stormConfig)
focal_class.class_method_signature: BasicMetricsCollector.pollNimbus(Nimbus.Client client, long now, MetricsState state, PrintWriter writer)
focal_class.full_signature:  boolean pollNimbus(Nimbus.Client client, long now, MetricsState state, PrintWriter writer)
focal_class.identifier: pollNimbus
focal_class.parameters: (Nimbus.Client client, long now, MetricsState state, PrintWriter writer)
focal_class.return: boolean
focal_class.signature: boolean pollNimbus(Nimbus.Client client, long now, MetricsState state, PrintWriter writer)
focal_class.class_method_signature: BasicMetricsCollector.updateTopologyStats(TopologySummary ts, MetricsState state, long now)
focal_class.full_signature:  void updateTopologyStats(TopologySummary ts, MetricsState state, long now)
focal_class.identifier: updateTopologyStats
focal_class.parameters: (TopologySummary ts, MetricsState state, long now)
focal_class.return: void
focal_class.signature: void updateTopologyStats(TopologySummary ts, MetricsState state, long now)
focal_class.class_method_signature: BasicMetricsCollector.updateSupervisorStats(ClusterSummary cs)
focal_class.full_signature:  void updateSupervisorStats(ClusterSummary cs)
focal_class.identifier: updateSupervisorStats
focal_class.parameters: (ClusterSummary cs)
focal_class.return: void
focal_class.signature: void updateSupervisorStats(ClusterSummary cs)
focal_class.class_method_signature: BasicMetricsCollector.updateExecutorStats(TopologyInfo info, MetricsState state, long now)
focal_class.full_signature:  void updateExecutorStats(TopologyInfo info, MetricsState state, long now)
focal_class.identifier: updateExecutorStats
focal_class.parameters: (TopologyInfo info, MetricsState state, long now)
focal_class.return: void
focal_class.signature: void updateExecutorStats(TopologyInfo info, MetricsState state, long now)
focal_class.class_method_signature: BasicMetricsCollector.isSpout(ExecutorSpecificStats specs)
focal_class.full_signature:  boolean isSpout(ExecutorSpecificStats specs)
focal_class.identifier: isSpout
focal_class.parameters: (ExecutorSpecificStats specs)
focal_class.return: boolean
focal_class.signature: boolean isSpout(ExecutorSpecificStats specs)
focal_class.class_method_signature: BasicMetricsCollector.isDefaultStream(String stream)
focal_class.full_signature:  boolean isDefaultStream(String stream)
focal_class.identifier: isDefaultStream
focal_class.parameters: (String stream)
focal_class.return: boolean
focal_class.signature: boolean isDefaultStream(String stream)
focal_class.class_method_signature: BasicMetricsCollector.isBatchStream(String stream)
focal_class.full_signature:  boolean isBatchStream(String stream)
focal_class.identifier: isBatchStream
focal_class.parameters: (String stream)
focal_class.return: boolean
focal_class.signature: boolean isBatchStream(String stream)
focal_class.class_method_signature: BasicMetricsCollector.writeHeader(PrintWriter writer)
focal_class.full_signature:  void writeHeader(PrintWriter writer)
focal_class.identifier: writeHeader
focal_class.parameters: (PrintWriter writer)
focal_class.return: void
focal_class.signature: void writeHeader(PrintWriter writer)
focal_class.class_method_signature: BasicMetricsCollector.writeLine(PrintWriter writer)
focal_class.full_signature:  void writeLine(PrintWriter writer)
focal_class.identifier: writeLine
focal_class.parameters: (PrintWriter writer)
focal_class.return: void
focal_class.signature: void writeLine(PrintWriter writer)
focal_class.class_method_signature: BasicMetricsCollector.collectSupervisorStats(Set<MetricsItem> items)
focal_class.full_signature:  boolean collectSupervisorStats(Set<MetricsItem> items)
focal_class.identifier: collectSupervisorStats
focal_class.parameters: (Set<MetricsItem> items)
focal_class.return: boolean
focal_class.signature: boolean collectSupervisorStats(Set<MetricsItem> items)
focal_class.class_method_signature: BasicMetricsCollector.collectTopologyStats(Set<MetricsItem> items)
focal_class.full_signature:  boolean collectTopologyStats(Set<MetricsItem> items)
focal_class.identifier: collectTopologyStats
focal_class.parameters: (Set<MetricsItem> items)
focal_class.return: boolean
focal_class.signature: boolean collectTopologyStats(Set<MetricsItem> items)
focal_class.class_method_signature: BasicMetricsCollector.collectExecutorStats(Set<MetricsItem> items)
focal_class.full_signature:  boolean collectExecutorStats(Set<MetricsItem> items)
focal_class.identifier: collectExecutorStats
focal_class.parameters: (Set<MetricsItem> items)
focal_class.return: boolean
focal_class.signature: boolean collectExecutorStats(Set<MetricsItem> items)
focal_class.class_method_signature: BasicMetricsCollector.collectThroughput(Set<MetricsItem> items)
focal_class.full_signature:  boolean collectThroughput(Set<MetricsItem> items)
focal_class.identifier: collectThroughput
focal_class.parameters: (Set<MetricsItem> items)
focal_class.return: boolean
focal_class.signature: boolean collectThroughput(Set<MetricsItem> items)
focal_class.class_method_signature: BasicMetricsCollector.collectThroughputMB(Set<MetricsItem> items)
focal_class.full_signature:  boolean collectThroughputMB(Set<MetricsItem> items)
focal_class.identifier: collectThroughputMB
focal_class.parameters: (Set<MetricsItem> items)
focal_class.return: boolean
focal_class.signature: boolean collectThroughputMB(Set<MetricsItem> items)
focal_class.class_method_signature: BasicMetricsCollector.collectSpoutThroughput(Set<MetricsItem> items)
focal_class.full_signature:  boolean collectSpoutThroughput(Set<MetricsItem> items)
focal_class.identifier: collectSpoutThroughput
focal_class.parameters: (Set<MetricsItem> items)
focal_class.return: boolean
focal_class.signature: boolean collectSpoutThroughput(Set<MetricsItem> items)
focal_class.class_method_signature: BasicMetricsCollector.collectSpoutLatency(Set<MetricsItem> items)
focal_class.full_signature:  boolean collectSpoutLatency(Set<MetricsItem> items)
focal_class.identifier: collectSpoutLatency
focal_class.parameters: (Set<MetricsItem> items)
focal_class.return: boolean
focal_class.signature: boolean collectSpoutLatency(Set<MetricsItem> items)
focal_method.body: boolean collectSpoutLatency(Set<MetricsItem> items) {
      return items.contains(MetricsItem.ALL) ||
              items.contains(MetricsItem.SPOUT_LATENCY);
    }
focal_method.class_method_signature: BasicMetricsCollector.collectSpoutLatency(Set<MetricsItem> items)
focal_method.full_signature:  boolean collectSpoutLatency(Set<MetricsItem> items)
focal_method.identifier: collectSpoutLatency
focal_method.invocations: contains contains
focal_method.parameters: (Set<MetricsItem> items)
focal_method.return: boolean
focal_method.signature: boolean collectSpoutLatency(Set<MetricsItem> items)