@Test public void testFlush() { BatchOutputCollector collector = new BatchOutputCollector(null, null, 0); collector.flush(); verify(collectorMock).flush(); }
public void flush() { this.batcher.flush(); }
BatchOutputCollector extends OutputCollector { public void flush() { this.batcher.flush(); } }
BatchOutputCollector extends OutputCollector { public void flush() { this.batcher.flush(); } BatchOutputCollector(TopologyContext context, IOutputCollector collector, int batchSize);  BatchOutputCollector(TopologyContext context, IOutputCollector collector, Map<String, Integer> batchSizes); }
BatchOutputCollector extends OutputCollector { public void flush() { this.batcher.flush(); } BatchOutputCollector(TopologyContext context, IOutputCollector collector, int batchSize);  BatchOutputCollector(TopologyContext context, IOutputCollector collector, Map<String, Integer> batchSizes); @Override List<Integer> emit(String streamId, Tuple anchor, List<Object> tuple); @Override List<Integer> emit(String streamId, List<Object> tuple); @Override List<Integer> emit(Collection<Tuple> anchors, List<Object> tuple); @Override List<Integer> emit(Tuple anchor, List<Object> tuple); @Override List<Integer> emit(List<Object> tuple); @Override void emitDirect(int taskId, String streamId, Tuple anchor, List<Object> tuple); @Override void emitDirect(int taskId, String streamId, List<Object> tuple); @Override void emitDirect(int taskId, Collection<Tuple> anchors, List<Object> tuple); @Override void emitDirect(int taskId, Tuple anchor, List<Object> tuple); @Override void emitDirect(int taskId, List<Object> tuple); @Override List<Integer> emit(String streamId, Collection<Tuple> anchors, List<Object> tuple); @Override void emitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple); @Override void ack(Tuple input); @Override void fail(Tuple input); @Override void reportError(Throwable error); void flush(); }
BatchOutputCollector extends OutputCollector { public void flush() { this.batcher.flush(); } BatchOutputCollector(TopologyContext context, IOutputCollector collector, int batchSize);  BatchOutputCollector(TopologyContext context, IOutputCollector collector, Map<String, Integer> batchSizes); @Override List<Integer> emit(String streamId, Tuple anchor, List<Object> tuple); @Override List<Integer> emit(String streamId, List<Object> tuple); @Override List<Integer> emit(Collection<Tuple> anchors, List<Object> tuple); @Override List<Integer> emit(Tuple anchor, List<Object> tuple); @Override List<Integer> emit(List<Object> tuple); @Override void emitDirect(int taskId, String streamId, Tuple anchor, List<Object> tuple); @Override void emitDirect(int taskId, String streamId, List<Object> tuple); @Override void emitDirect(int taskId, Collection<Tuple> anchors, List<Object> tuple); @Override void emitDirect(int taskId, Tuple anchor, List<Object> tuple); @Override void emitDirect(int taskId, List<Object> tuple); @Override List<Integer> emit(String streamId, Collection<Tuple> anchors, List<Object> tuple); @Override void emitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple); @Override void ack(Tuple input); @Override void fail(Tuple input); @Override void reportError(Throwable error); void flush();  }