@Test(expected = AssertionError.class) public void testBatchEmitDirectAnchors() { BatchOutputCollector collector = mock(BatchOutputCollector.class); BoltBatchCollectorImpl collectorImpl = new BoltBatchCollectorImpl(collector, mock(TopologyContext.class), 0); collectorImpl.doEmitDirect(0, null, null, null, mock(Object.class)); }
@SuppressWarnings({"rawtypes", "unchecked"}) @Override protected void doEmitDirect(int taskId, String streamId, Collection<Tuple> anchors, Object tupleOrBatch, Object messageId) { assert (messageId == null); BatchOutputCollector.logger.trace("taskId: {}; streamId: {}; anchors: {}, tuple/batch: {}", new Integer(taskId), streamId, anchors, tupleOrBatch); this.boltBatchCollector.collector.emitDirect(taskId, streamId, anchors, (List)tupleOrBatch); }
BoltBatchCollectorImpl extends AbstractBatchCollector { @SuppressWarnings({"rawtypes", "unchecked"}) @Override protected void doEmitDirect(int taskId, String streamId, Collection<Tuple> anchors, Object tupleOrBatch, Object messageId) { assert (messageId == null); BatchOutputCollector.logger.trace("taskId: {}; streamId: {}; anchors: {}, tuple/batch: {}", new Integer(taskId), streamId, anchors, tupleOrBatch); this.boltBatchCollector.collector.emitDirect(taskId, streamId, anchors, (List)tupleOrBatch); } }
BoltBatchCollectorImpl extends AbstractBatchCollector { @SuppressWarnings({"rawtypes", "unchecked"}) @Override protected void doEmitDirect(int taskId, String streamId, Collection<Tuple> anchors, Object tupleOrBatch, Object messageId) { assert (messageId == null); BatchOutputCollector.logger.trace("taskId: {}; streamId: {}; anchors: {}, tuple/batch: {}", new Integer(taskId), streamId, anchors, tupleOrBatch); this.boltBatchCollector.collector.emitDirect(taskId, streamId, anchors, (List)tupleOrBatch); } BoltBatchCollectorImpl(BatchOutputCollector boltBatchCollector, TopologyContext context, int batchSize);  BoltBatchCollectorImpl(BatchOutputCollector boltBatchCollector, TopologyContext context,
		Map<String, Integer> batchSizes); }
BoltBatchCollectorImpl extends AbstractBatchCollector { @SuppressWarnings({"rawtypes", "unchecked"}) @Override protected void doEmitDirect(int taskId, String streamId, Collection<Tuple> anchors, Object tupleOrBatch, Object messageId) { assert (messageId == null); BatchOutputCollector.logger.trace("taskId: {}; streamId: {}; anchors: {}, tuple/batch: {}", new Integer(taskId), streamId, anchors, tupleOrBatch); this.boltBatchCollector.collector.emitDirect(taskId, streamId, anchors, (List)tupleOrBatch); } BoltBatchCollectorImpl(BatchOutputCollector boltBatchCollector, TopologyContext context, int batchSize);  BoltBatchCollectorImpl(BatchOutputCollector boltBatchCollector, TopologyContext context,
		Map<String, Integer> batchSizes);  }
BoltBatchCollectorImpl extends AbstractBatchCollector { @SuppressWarnings({"rawtypes", "unchecked"}) @Override protected void doEmitDirect(int taskId, String streamId, Collection<Tuple> anchors, Object tupleOrBatch, Object messageId) { assert (messageId == null); BatchOutputCollector.logger.trace("taskId: {}; streamId: {}; anchors: {}, tuple/batch: {}", new Integer(taskId), streamId, anchors, tupleOrBatch); this.boltBatchCollector.collector.emitDirect(taskId, streamId, anchors, (List)tupleOrBatch); } BoltBatchCollectorImpl(BatchOutputCollector boltBatchCollector, TopologyContext context, int batchSize);  BoltBatchCollectorImpl(BatchOutputCollector boltBatchCollector, TopologyContext context,
		Map<String, Integer> batchSizes);   }