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 = mock(StormTopology.class)
test_class.modifier: private static final
test_class.original_string: private static final StormTopology topology = mock(StormTopology.class);
test_class.type: StormTopology
test_class.var_name: topology
test_class.file: storm/storm-benchmark/src/test/java/storm/benchmark/benchmarks/common/StormBenchmarkTest.java
test_class.identifier: StormBenchmarkTest
test_case.body: @Test(dataProvider = "getStormBenchmark")
    public void getMetricsCollectorShouldReturnProperCollector(
            StormBenchmark benchmark, Class collectorClass) {
      IMetricsCollector collector = benchmark.getMetricsCollector(config, topology);
      assertThat(collector)
              .isNotNull()
              .isInstanceOf(collectorClass);
    }
test_case.class_method_signature: StormBenchmarkTest.getMetricsCollectorShouldReturnProperCollector(
            StormBenchmark benchmark, Class collectorClass)
test_case.full_signature: @Test(dataProvider = "getStormBenchmark") public void getMetricsCollectorShouldReturnProperCollector(
            StormBenchmark benchmark, Class collectorClass)
test_case.identifier: getMetricsCollectorShouldReturnProperCollector
test_case.invocations: getMetricsCollector isInstanceOf isNotNull assertThat
test_case.modifiers: @Test(dataProvider = "getStormBenchmark") public
test_case.parameters: (
            StormBenchmark benchmark, Class collectorClass)
test_case.return: void
test_case.signature: void getMetricsCollectorShouldReturnProperCollector(
            StormBenchmark benchmark, Class collectorClass)
focal_class.declarator: LOG = Logger.getLogger(StormBenchmark.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = Logger.getLogger(StormBenchmark.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: DEFAULT_TOPOLOGY_NAME = "benchmark"
focal_class.modifier: public static final
focal_class.original_string: public static final String DEFAULT_TOPOLOGY_NAME = "benchmark";
focal_class.type: String
focal_class.var_name: DEFAULT_TOPOLOGY_NAME
focal_class.file: storm/storm-benchmark/src/main/java/storm/benchmark/benchmarks/common/StormBenchmark.java
focal_class.identifier: StormBenchmark
focal_class.interfaces: implements IBenchmark
focal_class.class_method_signature: StormBenchmark.getMetricsCollector(Config config, StormTopology topology)
focal_class.full_signature: @Override public IMetricsCollector getMetricsCollector(Config config, StormTopology topology)
focal_class.identifier: getMetricsCollector
focal_class.modifiers: @Override public
focal_class.parameters: (Config config, StormTopology topology)
focal_class.return: IMetricsCollector
focal_class.signature: IMetricsCollector getMetricsCollector(Config config, StormTopology topology)
focal_method.body: @Override
    public IMetricsCollector getMetricsCollector(Config config, StormTopology topology) {
  
      Set<MetricsItem> items = Sets.newHashSet(
              MetricsItem.SUPERVISOR_STATS,
              MetricsItem.TOPOLOGY_STATS,
              MetricsItem.THROUGHPUT,
              MetricsItem.SPOUT_THROUGHPUT,
              MetricsItem.SPOUT_LATENCY
              );
      return new BasicMetricsCollector(config, topology, items);
    }
focal_method.class_method_signature: StormBenchmark.getMetricsCollector(Config config, StormTopology topology)
focal_method.full_signature: @Override public IMetricsCollector getMetricsCollector(Config config, StormTopology topology)
focal_method.identifier: getMetricsCollector
focal_method.invocations: newHashSet
focal_method.modifiers: @Override public
focal_method.parameters: (Config config, StormTopology topology)
focal_method.return: IMetricsCollector
focal_method.signature: IMetricsCollector getMetricsCollector(Config config, StormTopology topology)