@Test public void testGetComponentConfiguration() { SpoutOutputBatcher spout = new SpoutOutputBatcher(this.spoutMock, this.noBatching); final Map<String, Object> conf = new HashMap<String, Object>(); when(spout.getComponentConfiguration()).thenReturn(conf); Map<String, Object> result = spout.getComponentConfiguration(); verify(this.spoutMock).getComponentConfiguration(); Assert.assertSame(result, conf); }
@Override public Map<String, Object> getComponentConfiguration() { return this.wrappedSpout.getComponentConfiguration(); }
SpoutOutputBatcher implements IRichSpout { @Override public Map<String, Object> getComponentConfiguration() { return this.wrappedSpout.getComponentConfiguration(); } }
SpoutOutputBatcher implements IRichSpout { @Override public Map<String, Object> getComponentConfiguration() { return this.wrappedSpout.getComponentConfiguration(); } SpoutOutputBatcher(IRichSpout spout, int batchSize);  SpoutOutputBatcher(IRichSpout spout, Map<String, Integer> batchSizes); }
SpoutOutputBatcher implements IRichSpout { @Override public Map<String, Object> getComponentConfiguration() { return this.wrappedSpout.getComponentConfiguration(); } SpoutOutputBatcher(IRichSpout spout, int batchSize);  SpoutOutputBatcher(IRichSpout spout, Map<String, Integer> batchSizes); @Override void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector); @Override void close(); @Override void activate(); @Override void deactivate(); @Override void nextTuple(); @Override void ack(Object msgId); @Override void fail(Object msgId); @Override void declareOutputFields(OutputFieldsDeclarer declarer); @Override Map<String, Object> getComponentConfiguration(); static void registerKryoClasses(Config stormConfig); }
SpoutOutputBatcher implements IRichSpout { @Override public Map<String, Object> getComponentConfiguration() { return this.wrappedSpout.getComponentConfiguration(); } SpoutOutputBatcher(IRichSpout spout, int batchSize);  SpoutOutputBatcher(IRichSpout spout, Map<String, Integer> batchSizes); @Override void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector); @Override void close(); @Override void activate(); @Override void deactivate(); @Override void nextTuple(); @Override void ack(Object msgId); @Override void fail(Object msgId); @Override void declareOutputFields(OutputFieldsDeclarer declarer); @Override Map<String, Object> getComponentConfiguration(); static void registerKryoClasses(Config stormConfig);  }