@Test public void testEmitDirectAnchorsTuple() { BatchOutputCollector collector = new BatchOutputCollector(null, null, 0); collector.emitDirect(taskId, anchors, tuple); verify(collectorMock).tupleEmitDirect(taskId, Utils.DEFAULT_STREAM_ID, anchors, tuple, null); }
@Override public void emitDirect(int taskId, String streamId, Tuple anchor, List<Object> tuple) { this.emitDirect(taskId, streamId, Arrays.asList(anchor), tuple); }
BatchOutputCollector extends OutputCollector { @Override public void emitDirect(int taskId, String streamId, Tuple anchor, List<Object> tuple) { this.emitDirect(taskId, streamId, Arrays.asList(anchor), tuple); } }
BatchOutputCollector extends OutputCollector { @Override public void emitDirect(int taskId, String streamId, Tuple anchor, List<Object> tuple) { this.emitDirect(taskId, streamId, Arrays.asList(anchor), tuple); } BatchOutputCollector(TopologyContext context, IOutputCollector collector, int batchSize);  BatchOutputCollector(TopologyContext context, IOutputCollector collector, Map<String, Integer> batchSizes); }
BatchOutputCollector extends OutputCollector { @Override public void emitDirect(int taskId, String streamId, Tuple anchor, List<Object> tuple) { this.emitDirect(taskId, streamId, Arrays.asList(anchor), tuple); } 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 { @Override public void emitDirect(int taskId, String streamId, Tuple anchor, List<Object> tuple) { this.emitDirect(taskId, streamId, Arrays.asList(anchor), tuple); } 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();  }