@Test public void testCleanup() { IRichBolt boltMock = mock(IRichBolt.class); InputDebatcher bolt = new InputDebatcher(boltMock); bolt.cleanup(); verify(boltMock).cleanup(); }
@Override public void cleanup() { this.wrappedBolt.cleanup(); }
InputDebatcher implements IRichBolt { @Override public void cleanup() { this.wrappedBolt.cleanup(); } }
InputDebatcher implements IRichBolt { @Override public void cleanup() { this.wrappedBolt.cleanup(); } InputDebatcher(IRichBolt bolt); }
InputDebatcher implements IRichBolt { @Override public void cleanup() { this.wrappedBolt.cleanup(); } 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 cleanup() { this.wrappedBolt.cleanup(); } 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);  }