@Test public void testGetComponentConfiguration() { Assert.assertSame(boltConfig, checker.getComponentConfiguration()); }
@Override public Map<String, Object> getComponentConfiguration() { return this.wrappedBolt.getComponentConfiguration(); }
TimestampMerger implements IRichBolt { @Override public Map<String, Object> getComponentConfiguration() { return this.wrappedBolt.getComponentConfiguration(); } }
TimestampMerger implements IRichBolt { @Override public Map<String, Object> getComponentConfiguration() { return this.wrappedBolt.getComponentConfiguration(); } TimestampMerger(IRichBolt wrappedBolt, int tsIndex);  TimestampMerger(IRichBolt wrappedBolt, String tsAttributeName);  TimestampMerger(IRichBolt wrappedBolt, TimeStampExtractor<Tuple> tsExtractor); }
TimestampMerger implements IRichBolt { @Override public Map<String, Object> getComponentConfiguration() { return this.wrappedBolt.getComponentConfiguration(); } 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 Map<String, Object> getComponentConfiguration() { return this.wrappedBolt.getComponentConfiguration(); } 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; }