test_class.file: storm/storm-benchmark/src/test/java/storm/benchmark/benchmarks/PageViewCountTest.java
test_class.identifier: PageViewCountTest
test_case.body: @Test
    public void componentParallelismCouldBeSetThroughConfig() {
      StormBenchmark benchmark = new PageViewCount();
      Config config = new Config();
      config.put(PageViewCount.SPOUT_NUM, 3);
      config.put(PageViewCount.VIEW_NUM, 4);
      config.put(PageViewCount.COUNT_NUM, 5);
  
      StormTopology topology = benchmark.getTopology(config);
      assertThat(topology).isNotNull();
      TestUtils.verifyParallelism(Utils.getComponentCommon(topology, PageViewCount.SPOUT_ID), 3);
      TestUtils.verifyParallelism(Utils.getComponentCommon(topology, PageViewCount.VIEW_ID), 4);
      TestUtils.verifyParallelism(Utils.getComponentCommon(topology, PageViewCount.COUNT_ID), 5);
    }
test_case.class_method_signature: PageViewCountTest.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.declarator: SPOUT_ID = "spout"
focal_class.modifier: public static final
focal_class.original_string: public static final String SPOUT_ID = "spout";
focal_class.type: String
focal_class.var_name: SPOUT_ID
focal_class.declarator: SPOUT_NUM = "component.spout_num"
focal_class.modifier: public static final
focal_class.original_string: public static final String SPOUT_NUM = "component.spout_num";
focal_class.type: String
focal_class.var_name: SPOUT_NUM
focal_class.declarator: VIEW_ID = "view"
focal_class.modifier: public static final
focal_class.original_string: public static final String VIEW_ID = "view";
focal_class.type: String
focal_class.var_name: VIEW_ID
focal_class.declarator: VIEW_NUM = "component.view_bolt_num"
focal_class.modifier: public static final
focal_class.original_string: public static final String VIEW_NUM = "component.view_bolt_num";
focal_class.type: String
focal_class.var_name: VIEW_NUM
focal_class.declarator: COUNT_ID = "count"
focal_class.modifier: public static final
focal_class.original_string: public static final String COUNT_ID = "count";
focal_class.type: String
focal_class.var_name: COUNT_ID
focal_class.declarator: COUNT_NUM = "component.count_bolt_num"
focal_class.modifier: public static final
focal_class.original_string: public static final String COUNT_NUM = "component.count_bolt_num";
focal_class.type: String
focal_class.var_name: COUNT_NUM
focal_class.declarator: DEFAULT_SPOUT_NUM = 4
focal_class.modifier: public static final
focal_class.original_string: public static final int DEFAULT_SPOUT_NUM = 4;
focal_class.type: int
focal_class.var_name: DEFAULT_SPOUT_NUM
focal_class.declarator: DEFAULT_VIEW_BOLT_NUM = 4
focal_class.modifier: public static final
focal_class.original_string: public static final int DEFAULT_VIEW_BOLT_NUM = 4;
focal_class.type: int
focal_class.var_name: DEFAULT_VIEW_BOLT_NUM
focal_class.declarator: DEFAULT_COUNT_BOLT_NUM = 4
focal_class.modifier: public static final
focal_class.original_string: public static final int DEFAULT_COUNT_BOLT_NUM = 4;
focal_class.type: int
focal_class.var_name: DEFAULT_COUNT_BOLT_NUM
focal_class.declarator: spout
focal_class.modifier: private
focal_class.original_string: private IRichSpout spout;
focal_class.type: IRichSpout
focal_class.var_name: spout
focal_class.file: storm/storm-benchmark/src/main/java/storm/benchmark/benchmarks/PageViewCount.java
focal_class.identifier: PageViewCount
focal_class.class_method_signature: PageViewCount.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 StormBenchmark
focal_method.body: @Override
    public StormTopology getTopology(Config config) {
  
      final int spoutNum = BenchmarkUtils.getInt(config, SPOUT_NUM, DEFAULT_SPOUT_NUM);
      final int viewBoltNum = BenchmarkUtils.getInt(config, VIEW_NUM, DEFAULT_VIEW_BOLT_NUM);
      final int cntBoltNum = BenchmarkUtils.getInt(config, COUNT_NUM, DEFAULT_COUNT_BOLT_NUM);
  
      spout = new KafkaSpout(KafkaUtils.getSpoutConfig(
              config, new SchemeAsMultiScheme(new StringScheme())));
  
      TopologyBuilder builder = new TopologyBuilder();
      builder.setSpout(SPOUT_ID, spout, spoutNum);
      builder.setBolt(VIEW_ID, new PageViewBolt(Item.URL, Item.ONE), viewBoltNum)
             .localOrShuffleGrouping(SPOUT_ID);
      builder.setBolt(COUNT_ID, new WordCount.Count(), cntBoltNum)
              .fieldsGrouping(VIEW_ID, new Fields(Item.URL.toString()));
      return builder.createTopology();
    }
focal_method.class_method_signature: PageViewCount.getTopology(Config config)
focal_method.full_signature: @Override public StormTopology getTopology(Config config)
focal_method.identifier: getTopology
focal_method.invocations: getInt getInt getInt getSpoutConfig setSpout localOrShuffleGrouping setBolt fieldsGrouping setBolt toString createTopology
focal_method.modifiers: @Override public
focal_method.parameters: (Config config)
focal_method.return: StormTopology
focal_method.signature: StormTopology getTopology(Config config)