@Test public void testOpen() { SpoutOutputBatcher spout = new SpoutOutputBatcher(this.spoutMock, this.noBatching); @SuppressWarnings("rawtypes") Map conf = new HashMap(); TopologyContext context = mock(TopologyContext.class); spout.open(conf, context, null); verify(this.spoutMock).open(same(conf), same(context), any(BatchSpoutOutputCollector.class)); }
@Override public void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector) { if(this.batchSizes != null) { this.batchCollector = new BatchSpoutOutputCollector(context, collector, this.batchSizes); } else { this.batchCollector = new BatchSpoutOutputCollector(context, collector, this.batchSize); } this.wrappedSpout.open(conf, context, this.batchCollector); }
SpoutOutputBatcher implements IRichSpout { @Override public void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector) { if(this.batchSizes != null) { this.batchCollector = new BatchSpoutOutputCollector(context, collector, this.batchSizes); } else { this.batchCollector = new BatchSpoutOutputCollector(context, collector, this.batchSize); } this.wrappedSpout.open(conf, context, this.batchCollector); } }
SpoutOutputBatcher implements IRichSpout { @Override public void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector) { if(this.batchSizes != null) { this.batchCollector = new BatchSpoutOutputCollector(context, collector, this.batchSizes); } else { this.batchCollector = new BatchSpoutOutputCollector(context, collector, this.batchSize); } this.wrappedSpout.open(conf, context, this.batchCollector); } SpoutOutputBatcher(IRichSpout spout, int batchSize);  SpoutOutputBatcher(IRichSpout spout, Map<String, Integer> batchSizes); }
SpoutOutputBatcher implements IRichSpout { @Override public void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector) { if(this.batchSizes != null) { this.batchCollector = new BatchSpoutOutputCollector(context, collector, this.batchSizes); } else { this.batchCollector = new BatchSpoutOutputCollector(context, collector, this.batchSize); } this.wrappedSpout.open(conf, context, this.batchCollector); } SpoutOutputBatcher(IRichSpout spout, int batchSize);  SpoutOutputBatcher(IRichSpout spout, Map<String, Integer> batchSizes); @Override void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector); @Override void close(); @Override void activate(); @Override void deactivate(); @Override void nextTuple(); @Override void ack(Object msgId); @Override void fail(Object msgId); @Override void declareOutputFields(OutputFieldsDeclarer declarer); @Override Map<String, Object> getComponentConfiguration(); static void registerKryoClasses(Config stormConfig); }
SpoutOutputBatcher implements IRichSpout { @Override public void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector) { if(this.batchSizes != null) { this.batchCollector = new BatchSpoutOutputCollector(context, collector, this.batchSizes); } else { this.batchCollector = new BatchSpoutOutputCollector(context, collector, this.batchSize); } this.wrappedSpout.open(conf, context, this.batchCollector); } SpoutOutputBatcher(IRichSpout spout, int batchSize);  SpoutOutputBatcher(IRichSpout spout, Map<String, Integer> batchSizes); @Override void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector); @Override void close(); @Override void activate(); @Override void deactivate(); @Override void nextTuple(); @Override void ack(Object msgId); @Override void fail(Object msgId); @Override void declareOutputFields(OutputFieldsDeclarer declarer); @Override Map<String, Object> getComponentConfiguration(); static void registerKryoClasses(Config stormConfig);  }