@Test public void testFlush() { BatchSpoutOutputCollector collector = new BatchSpoutOutputCollector(null, null, 0); collector.flush(); verify(collectorMock).flush(); }
public void flush() { this.batcher.flush(); }
BatchSpoutOutputCollector extends SpoutOutputCollector { public void flush() { this.batcher.flush(); } }
BatchSpoutOutputCollector extends SpoutOutputCollector { public void flush() { this.batcher.flush(); } BatchSpoutOutputCollector(TopologyContext context, ISpoutOutputCollector collector, int batchSize);  BatchSpoutOutputCollector(TopologyContext context, ISpoutOutputCollector collector,
		Map<String, Integer> batchSizes); }
BatchSpoutOutputCollector extends SpoutOutputCollector { public void flush() { this.batcher.flush(); } 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 { public void flush() { this.batcher.flush(); } 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; }