@Test public void testEmitTuple() { BatchSpoutOutputCollector collector = new BatchSpoutOutputCollector(null, null, 0); collector.emit(tuple); verify(collectorMock).tupleEmit(Utils.DEFAULT_STREAM_ID, null, tuple, null); }
@Override public List<Integer> emit(String streamId, List<Object> tuple, Object messageId) { logger.trace("streamId: {}; tuple: {}; messageId: {}", streamId, tuple, messageId); this.tupleEmitted = true; return this.batcher.tupleEmit(streamId, null, tuple, messageId); }
BatchSpoutOutputCollector extends SpoutOutputCollector { @Override public List<Integer> emit(String streamId, List<Object> tuple, Object messageId) { logger.trace("streamId: {}; tuple: {}; messageId: {}", streamId, tuple, messageId); this.tupleEmitted = true; return this.batcher.tupleEmit(streamId, null, tuple, messageId); } }
BatchSpoutOutputCollector extends SpoutOutputCollector { @Override public List<Integer> emit(String streamId, List<Object> tuple, Object messageId) { logger.trace("streamId: {}; tuple: {}; messageId: {}", streamId, tuple, messageId); this.tupleEmitted = true; return this.batcher.tupleEmit(streamId, null, tuple, messageId); } BatchSpoutOutputCollector(TopologyContext context, ISpoutOutputCollector collector, int batchSize);  BatchSpoutOutputCollector(TopologyContext context, ISpoutOutputCollector collector,
		Map<String, Integer> batchSizes); }
BatchSpoutOutputCollector extends SpoutOutputCollector { @Override public List<Integer> emit(String streamId, List<Object> tuple, Object messageId) { logger.trace("streamId: {}; tuple: {}; messageId: {}", streamId, tuple, messageId); this.tupleEmitted = true; return this.batcher.tupleEmit(streamId, null, tuple, messageId); } BatchSpoutOutputCollector(TopologyContext context, ISpoutOutputCollector collector, int batchSize);  BatchSpoutOutputCollector(TopologyContext context, ISpoutOutputCollector collector,
		Map<String, Integer> batchSizes); @Override List<Integer> emit(String streamId, List<Object> tuple, Object messageId); @Override List<Integer> emit(List<Object> tuple, Object messageId); @Override List<Integer> emit(List<Object> tuple); @Override List<Integer> emit(String streamId, List<Object> tuple); @Override void emitDirect(int taskId, String streamId, List<Object> tuple, Object messageId); @Override void emitDirect(int taskId, List<Object> tuple, Object messageId); @Override void emitDirect(int taskId, String streamId, List<Object> tuple); @Override void emitDirect(int taskId, List<Object> tuple); void flush(); }
BatchSpoutOutputCollector extends SpoutOutputCollector { @Override public List<Integer> emit(String streamId, List<Object> tuple, Object messageId) { logger.trace("streamId: {}; tuple: {}; messageId: {}", streamId, tuple, messageId); this.tupleEmitted = true; return this.batcher.tupleEmit(streamId, null, tuple, messageId); } BatchSpoutOutputCollector(TopologyContext context, ISpoutOutputCollector collector, int batchSize);  BatchSpoutOutputCollector(TopologyContext context, ISpoutOutputCollector collector,
		Map<String, Integer> batchSizes); @Override List<Integer> emit(String streamId, List<Object> tuple, Object messageId); @Override List<Integer> emit(List<Object> tuple, Object messageId); @Override List<Integer> emit(List<Object> tuple); @Override List<Integer> emit(String streamId, List<Object> tuple); @Override void emitDirect(int taskId, String streamId, List<Object> tuple, Object messageId); @Override void emitDirect(int taskId, List<Object> tuple, Object messageId); @Override void emitDirect(int taskId, String streamId, List<Object> tuple); @Override void emitDirect(int taskId, List<Object> tuple); void flush(); public boolean tupleEmitted; public boolean batchEmitted; }