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 SummaryMethods inherited from interface org.apache.storm.task.IErrorReporterreportError
- 
Method Details- 
emitReturns the task ids that received the tuples.
- 
emitDirect
- 
getPendingCountlong getPendingCount()
- 
flushvoid flush()
 
-