@Test public void testOpen() { IRichBolt boltMock = mock(IRichBolt.class); InputDebatcher bolt = new InputDebatcher(boltMock); @SuppressWarnings("rawtypes") Map conf = new HashMap(); TopologyContext context = mock(TopologyContext.class); bolt.prepare(conf, context, null); verify(boltMock).prepare(same(conf), same(context), any(BatchOutputCollector.class)); }
@Override public void prepare(@SuppressWarnings("rawtypes") Map stormConf, TopologyContext context, OutputCollector collector) { this.topologyContext = context; this.wrappedBolt.prepare(stormConf, context, collector); }
InputDebatcher implements IRichBolt { @Override public void prepare(@SuppressWarnings("rawtypes") Map stormConf, TopologyContext context, OutputCollector collector) { this.topologyContext = context; this.wrappedBolt.prepare(stormConf, context, collector); } }
InputDebatcher implements IRichBolt { @Override public void prepare(@SuppressWarnings("rawtypes") Map stormConf, TopologyContext context, OutputCollector collector) { this.topologyContext = context; this.wrappedBolt.prepare(stormConf, context, collector); } InputDebatcher(IRichBolt bolt); }
InputDebatcher implements IRichBolt { @Override public void prepare(@SuppressWarnings("rawtypes") Map stormConf, TopologyContext context, OutputCollector collector) { this.topologyContext = context; this.wrappedBolt.prepare(stormConf, context, collector); } InputDebatcher(IRichBolt bolt); @Override void prepare(@SuppressWarnings("rawtypes") Map stormConf, TopologyContext context, OutputCollector collector); @Override void execute(Tuple input); @Override void cleanup(); @Override void declareOutputFields(OutputFieldsDeclarer declarer); @Override Map<String, Object> getComponentConfiguration(); static void registerKryoClasses(Config stormConfig); }
InputDebatcher implements IRichBolt { @Override public void prepare(@SuppressWarnings("rawtypes") Map stormConf, TopologyContext context, OutputCollector collector) { this.topologyContext = context; this.wrappedBolt.prepare(stormConf, context, collector); } InputDebatcher(IRichBolt bolt); @Override void prepare(@SuppressWarnings("rawtypes") Map stormConf, TopologyContext context, OutputCollector collector); @Override void execute(Tuple input); @Override void cleanup(); @Override void declareOutputFields(OutputFieldsDeclarer declarer); @Override Map<String, Object> getComponentConfiguration(); static void registerKryoClasses(Config stormConfig);  }