Package org.apache.storm.spout
Interface ISpoutOutputCollector
- All Superinterfaces:
IErrorReporter
- All Known Implementing Classes:
SpoutOutputCollector
,SpoutOutputCollectorImpl
Methods are not expected to be thread safe. Each thread expected to have a separate instance of this type of object, or else externally
synchronize any shared instance.
-
Method Summary
Methods inherited from interface org.apache.storm.task.IErrorReporter
reportError
-
Method Details
-
emit
Returns the task ids that received the tuples. -
emitDirect
-
getPendingCount
long getPendingCount() -
flush
void flush()
-