Package org.apache.storm.task
Interface IOutputCollector
- All Superinterfaces:
IErrorReporter
- All Known Implementing Classes:
BaseStatefulBoltExecutor.AnchoringOutputCollector
,BoltOutputCollectorImpl
,CoordinatedBolt.CoordinatedOutputCollector
,OutputCollector
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Returns the task ids that received the tuples.void
emitDirect
(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple) void
void
flush()
void
resetTimeout
(Tuple input) Methods inherited from interface org.apache.storm.task.IErrorReporter
reportError
-
Method Details
-
emit
Returns the task ids that received the tuples. -
emitDirect
-
ack
-
fail
-
resetTimeout
-
flush
void flush()
-