@Test public void testCleanup() { checker.cleanup(); verify(boltMockStatic).cleanup(); verify(boltMockStatic, atMost(1)).cleanup(); }
@Override public void cleanup() { this.wrappedBolt.cleanup(); }
TimestampMerger implements IRichBolt { @Override public void cleanup() { this.wrappedBolt.cleanup(); } }
TimestampMerger implements IRichBolt { @Override public void cleanup() { this.wrappedBolt.cleanup(); } TimestampMerger(IRichBolt wrappedBolt, int tsIndex);  TimestampMerger(IRichBolt wrappedBolt, String tsAttributeName);  TimestampMerger(IRichBolt wrappedBolt, TimeStampExtractor<Tuple> tsExtractor); }
TimestampMerger implements IRichBolt { @Override public void cleanup() { this.wrappedBolt.cleanup(); } TimestampMerger(IRichBolt wrappedBolt, int tsIndex);  TimestampMerger(IRichBolt wrappedBolt, String tsAttributeName);  TimestampMerger(IRichBolt wrappedBolt, TimeStampExtractor<Tuple> tsExtractor); @Override void prepare(@SuppressWarnings("rawtypes") Map arg0, TopologyContext arg1, OutputCollector arg2); @Override void execute(Tuple tuple); @Override void declareOutputFields(OutputFieldsDeclarer arg0); @Override Map<String, Object> getComponentConfiguration(); @Override void cleanup(); }
TimestampMerger implements IRichBolt { @Override public void cleanup() { this.wrappedBolt.cleanup(); } TimestampMerger(IRichBolt wrappedBolt, int tsIndex);  TimestampMerger(IRichBolt wrappedBolt, String tsAttributeName);  TimestampMerger(IRichBolt wrappedBolt, TimeStampExtractor<Tuple> tsExtractor); @Override void prepare(@SuppressWarnings("rawtypes") Map arg0, TopologyContext arg1, OutputCollector arg2); @Override void execute(Tuple tuple); @Override void declareOutputFields(OutputFieldsDeclarer arg0); @Override Map<String, Object> getComponentConfiguration(); @Override void cleanup(); final static String FLUSH_STREAM_ID; }