@SuppressWarnings("unchecked") @Test(expected = AssertionError.class) public void testBatchEmitAnchors() { BatchSpoutOutputCollector collector = mock(BatchSpoutOutputCollector.class); SpoutBatchCollectorImpl collectorImpl = new SpoutBatchCollectorImpl(collector, mock(TopologyContext.class), 0); collectorImpl.doEmit(null, mock(Collection.class), null, null); }
@SuppressWarnings({"unchecked", "rawtypes"}) @Override protected List<Integer> doEmit(String streamId, Collection<Tuple> anchors, Object tupleOrBatch, Object messageId) { assert (anchors == null); logger.trace("streamId: {}; Tuple/batch: {}; messageId: {}", streamId, tupleOrBatch, messageId); this.spoutBatchCollector.batchEmitted = true; return this.spoutBatchCollector.collector.emit(streamId, (List)tupleOrBatch, messageId); }
SpoutBatchCollectorImpl extends AbstractBatchCollector { @SuppressWarnings({"unchecked", "rawtypes"}) @Override protected List<Integer> doEmit(String streamId, Collection<Tuple> anchors, Object tupleOrBatch, Object messageId) { assert (anchors == null); logger.trace("streamId: {}; Tuple/batch: {}; messageId: {}", streamId, tupleOrBatch, messageId); this.spoutBatchCollector.batchEmitted = true; return this.spoutBatchCollector.collector.emit(streamId, (List)tupleOrBatch, messageId); } }
SpoutBatchCollectorImpl extends AbstractBatchCollector { @SuppressWarnings({"unchecked", "rawtypes"}) @Override protected List<Integer> doEmit(String streamId, Collection<Tuple> anchors, Object tupleOrBatch, Object messageId) { assert (anchors == null); logger.trace("streamId: {}; Tuple/batch: {}; messageId: {}", streamId, tupleOrBatch, messageId); this.spoutBatchCollector.batchEmitted = true; return this.spoutBatchCollector.collector.emit(streamId, (List)tupleOrBatch, messageId); } SpoutBatchCollectorImpl(BatchSpoutOutputCollector spoutBatchCollector, TopologyContext context, int batchSize);  SpoutBatchCollectorImpl(BatchSpoutOutputCollector spoutBatchCollector, TopologyContext context,
		Map<String, Integer> batchSizes); }
SpoutBatchCollectorImpl extends AbstractBatchCollector { @SuppressWarnings({"unchecked", "rawtypes"}) @Override protected List<Integer> doEmit(String streamId, Collection<Tuple> anchors, Object tupleOrBatch, Object messageId) { assert (anchors == null); logger.trace("streamId: {}; Tuple/batch: {}; messageId: {}", streamId, tupleOrBatch, messageId); this.spoutBatchCollector.batchEmitted = true; return this.spoutBatchCollector.collector.emit(streamId, (List)tupleOrBatch, messageId); } SpoutBatchCollectorImpl(BatchSpoutOutputCollector spoutBatchCollector, TopologyContext context, int batchSize);  SpoutBatchCollectorImpl(BatchSpoutOutputCollector spoutBatchCollector, TopologyContext context,
		Map<String, Integer> batchSizes);  }
SpoutBatchCollectorImpl extends AbstractBatchCollector { @SuppressWarnings({"unchecked", "rawtypes"}) @Override protected List<Integer> doEmit(String streamId, Collection<Tuple> anchors, Object tupleOrBatch, Object messageId) { assert (anchors == null); logger.trace("streamId: {}; Tuple/batch: {}; messageId: {}", streamId, tupleOrBatch, messageId); this.spoutBatchCollector.batchEmitted = true; return this.spoutBatchCollector.collector.emit(streamId, (List)tupleOrBatch, messageId); } SpoutBatchCollectorImpl(BatchSpoutOutputCollector spoutBatchCollector, TopologyContext context, int batchSize);  SpoutBatchCollectorImpl(BatchSpoutOutputCollector spoutBatchCollector, TopologyContext context,
		Map<String, Integer> batchSizes);   }