@Test public void testSetBoltBatchSize() { IRichBolt userBolt = new TestBolt(); final int batchSize = this.r.nextInt(10); if(batchSize > 0) { this.topologyBuilder.setBolt(this.bolt1, new BoltOutputBatcher(new InputDebatcher(userBolt), batchSize)); } else { this.topologyBuilder.setBolt(this.bolt1, new BoltOutputBatcher(new InputDebatcher(userBolt), this.noBatching)); } this.aeolusBuilder.setBolt(this.bolt1, userBolt, batchSize); Assert.assertEquals(this.topologyBuilder.createTopology(), this.aeolusBuilder.createTopology()); }
@Override public BoltDeclarer setBolt(String id, IRichBolt bolt) { return this.setBolt(id, bolt, null, 0); }
AeolusBuilder extends TopologyBuilder { @Override public BoltDeclarer setBolt(String id, IRichBolt bolt) { return this.setBolt(id, bolt, null, 0); } }
AeolusBuilder extends TopologyBuilder { @Override public BoltDeclarer setBolt(String id, IRichBolt bolt) { return this.setBolt(id, bolt, null, 0); }  }
AeolusBuilder extends TopologyBuilder { @Override public BoltDeclarer setBolt(String id, IRichBolt bolt) { return this.setBolt(id, bolt, null, 0); }  @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 BoltDeclarer setBolt(String id, IRichBolt bolt) { return this.setBolt(id, bolt, null, 0); }  @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);  }