Package org.apache.storm.task
Interface IOutputCollector
- All Superinterfaces:
- IErrorReporter
- All Known Implementing Classes:
- BaseStatefulBoltExecutor.AnchoringOutputCollector,- BoltOutputCollectorImpl,- CoordinatedBolt.CoordinatedOutputCollector,- OutputCollector
- 
Method SummaryModifier and TypeMethodDescriptionvoidReturns the task ids that received the tuples.voidemitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple) voidvoidflush()voidresetTimeout(Tuple input) Methods inherited from interface org.apache.storm.task.IErrorReporterreportError
- 
Method Details- 
emitReturns the task ids that received the tuples.
- 
emitDirect
- 
ack
- 
fail
- 
resetTimeout
- 
flushvoid flush()
 
-