@Test public void testSetSpoutParallelismBatchSize() { IRichSpout userSpout = new TestSpout(); final Integer dop = new Integer(1 + this.r.nextInt(5)); final int batchSize = this.r.nextInt(10); if(batchSize > 0) { this.topologyBuilder.setSpout(this.spout1, new SpoutOutputBatcher(userSpout, batchSize), dop); } else { this.topologyBuilder.setSpout(this.spout1, new SpoutOutputBatcher(userSpout, this.noBatching), dop); } this.aeolusBuilder.setSpout(this.spout1, userSpout, dop, batchSize); Assert.assertEquals(this.topologyBuilder.createTopology(), this.aeolusBuilder.createTopology()); }
@Override public SpoutDeclarer setSpout(String id, IRichSpout spout) { return this.setSpout(id, spout, null, null); }
AeolusBuilder extends TopologyBuilder { @Override public SpoutDeclarer setSpout(String id, IRichSpout spout) { return this.setSpout(id, spout, null, null); } }
AeolusBuilder extends TopologyBuilder { @Override public SpoutDeclarer setSpout(String id, IRichSpout spout) { return this.setSpout(id, spout, null, null); }  }
AeolusBuilder extends TopologyBuilder { @Override public SpoutDeclarer setSpout(String id, IRichSpout spout) { return this.setSpout(id, spout, null, null); }  @Override BoltDeclarer setBolt(String id, IRichBolt bolt); BoltDeclarer setBolt(String id, IRichBolt bolt, int batchSize); BoltDeclarer setBolt(String id, IRichBolt bolt, HashMap<String, Integer> batchSizes); @Override BoltDeclarer setBolt(String id, IRichBolt bolt, Number parallelismHint); BoltDeclarer setBolt(String id, IRichBolt bolt, Number parallelismHint, int batchSize); BoltDeclarer setBolt(String id, IRichBolt bolt, Number parallelismHint, HashMap<String, Integer> batchSizes); @Override BoltDeclarer setBolt(String id, IBasicBolt bolt); @Override BoltDeclarer setBolt(String id, IBasicBolt bolt, Number parallelismHint); @Override SpoutDeclarer setSpout(String id, IRichSpout spout); SpoutDeclarer setSpout(String id, IRichSpout spout, int batchSize); SpoutDeclarer setSpout(String id, IRichSpout spout, Map<String, Integer> batchSizes); SpoutDeclarer setSpout(String id, IRichSpout spout, Number parallelismHint, int batchSize); SpoutDeclarer setSpout(String id, IRichSpout spout, Number parallelismHint, Map<String, Integer> batchSizes); @Override void setStateSpout(String id, IRichStateSpout stateSpout); @Override void setStateSpout(String id, IRichStateSpout stateSpout, Number parallelismHint); }
AeolusBuilder extends TopologyBuilder { @Override public SpoutDeclarer setSpout(String id, IRichSpout spout) { return this.setSpout(id, spout, null, null); }  @Override BoltDeclarer setBolt(String id, IRichBolt bolt); BoltDeclarer setBolt(String id, IRichBolt bolt, int batchSize); BoltDeclarer setBolt(String id, IRichBolt bolt, HashMap<String, Integer> batchSizes); @Override BoltDeclarer setBolt(String id, IRichBolt bolt, Number parallelismHint); BoltDeclarer setBolt(String id, IRichBolt bolt, Number parallelismHint, int batchSize); BoltDeclarer setBolt(String id, IRichBolt bolt, Number parallelismHint, HashMap<String, Integer> batchSizes); @Override BoltDeclarer setBolt(String id, IBasicBolt bolt); @Override BoltDeclarer setBolt(String id, IBasicBolt bolt, Number parallelismHint); @Override SpoutDeclarer setSpout(String id, IRichSpout spout); SpoutDeclarer setSpout(String id, IRichSpout spout, int batchSize); SpoutDeclarer setSpout(String id, IRichSpout spout, Map<String, Integer> batchSizes); SpoutDeclarer setSpout(String id, IRichSpout spout, Number parallelismHint, int batchSize); SpoutDeclarer setSpout(String id, IRichSpout spout, Number parallelismHint, Map<String, Integer> batchSizes); @Override void setStateSpout(String id, IRichStateSpout stateSpout); @Override void setStateSpout(String id, IRichStateSpout stateSpout, Number parallelismHint);  }