@Test public void testGetComponentConfiguration() { BoltOutputBatcher bolt = new BoltOutputBatcher(this.boltMock, this.noBatching); final Map<String, Object> conf = new HashMap<String, Object>(); when(bolt.getComponentConfiguration()).thenReturn(conf); Map<String, Object> result = bolt.getComponentConfiguration(); verify(this.boltMock).getComponentConfiguration(); Assert.assertSame(result, conf); }
@Override public Map<String, Object> getComponentConfiguration() { return this.wrappedBolt.getComponentConfiguration(); }
BoltOutputBatcher implements IRichBolt { @Override public Map<String, Object> getComponentConfiguration() { return this.wrappedBolt.getComponentConfiguration(); } }
BoltOutputBatcher implements IRichBolt { @Override public Map<String, Object> getComponentConfiguration() { return this.wrappedBolt.getComponentConfiguration(); } BoltOutputBatcher(IRichBolt bolt, int batchSize);  BoltOutputBatcher(IRichBolt bolt, Map<String, Integer> batchSizes); }
BoltOutputBatcher implements IRichBolt { @Override public Map<String, Object> getComponentConfiguration() { return this.wrappedBolt.getComponentConfiguration(); } BoltOutputBatcher(IRichBolt bolt, int batchSize);  BoltOutputBatcher(IRichBolt bolt, Map<String, Integer> batchSizes); @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); }
BoltOutputBatcher implements IRichBolt { @Override public Map<String, Object> getComponentConfiguration() { return this.wrappedBolt.getComponentConfiguration(); } BoltOutputBatcher(IRichBolt bolt, int batchSize);  BoltOutputBatcher(IRichBolt bolt, Map<String, Integer> batchSizes); @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);  }