test_class.file: storm/storm-benchmark/src/test/java/storm/benchmark/benchmarks/FileReadWordCountTest.java
test_class.identifier: FileReadWordCountTest
test_case.body: @Test
    public void componentParallelismCouldBeSetThroughConfig() {
      StormBenchmark benchmark = new FileReadWordCount();
      Config config = new Config();
      config.put(WordCount.SPOUT_NUM, 3);
      config.put(WordCount.SPLIT_NUM, 4);
      config.put(WordCount.COUNT_NUM, 5);
      StormTopology topology = benchmark.getTopology(config);
      assertThat(topology).isNotNull();
      TestUtils.verifyParallelism(Utils.getComponentCommon(topology, WordCount.SPOUT_ID), 3);
      TestUtils.verifyParallelism(Utils.getComponentCommon(topology, WordCount.SPLIT_ID), 4);
      TestUtils.verifyParallelism(Utils.getComponentCommon(topology, WordCount.COUNT_ID), 5);
    }
test_case.class_method_signature: FileReadWordCountTest.componentParallelismCouldBeSetThroughConfig()
test_case.full_signature: @Test public void componentParallelismCouldBeSetThroughConfig()
test_case.identifier: componentParallelismCouldBeSetThroughConfig
test_case.invocations: put put put getTopology isNotNull assertThat verifyParallelism getComponentCommon verifyParallelism getComponentCommon verifyParallelism getComponentCommon
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void componentParallelismCouldBeSetThroughConfig()
focal_class.file: storm/storm-benchmark/src/main/java/storm/benchmark/benchmarks/FileReadWordCount.java
focal_class.identifier: FileReadWordCount
focal_class.class_method_signature: FileReadWordCount.getTopology(Config config)
focal_class.full_signature: @Override public StormTopology getTopology(Config config)
focal_class.identifier: getTopology
focal_class.modifiers: @Override public
focal_class.parameters: (Config config)
focal_class.return: StormTopology
focal_class.signature: StormTopology getTopology(Config config)
focal_class.superclass: extends WordCount
focal_method.body: @Override
    public StormTopology getTopology(Config config) {
      spout = new FileReadSpout(BenchmarkUtils.ifAckEnabled(config));
      return super.getTopology(config);
    }
focal_method.class_method_signature: FileReadWordCount.getTopology(Config config)
focal_method.full_signature: @Override public StormTopology getTopology(Config config)
focal_method.identifier: getTopology
focal_method.invocations: ifAckEnabled getTopology
focal_method.modifiers: @Override public
focal_method.parameters: (Config config)
focal_method.return: StormTopology
focal_method.signature: StormTopology getTopology(Config config)