Package org.apache.storm.coordination
Class BatchOutputCollector
java.lang.Object
org.apache.storm.coordination.BatchOutputCollector
- Direct Known Subclasses:
- BatchOutputCollectorImpl
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionEmits a tuple to the default output stream.abstract voidemitDirect(int taskId, String streamId, List<Object> tuple) voidemitDirect(int taskId, List<Object> tuple) Emits a tuple to the specified task on the default output stream.abstract voidflush()Flush any buffered tuples (when batching is enabled).abstract voidreportError(Throwable error) 
- 
Constructor Details- 
BatchOutputCollectorpublic BatchOutputCollector()
 
- 
- 
Method Details- 
emitEmits a tuple to the default output stream.
- 
emit
- 
emitDirectEmits a tuple to the specified task on the default output stream. This output stream must have been declared as a direct stream, and the specified task must use a direct grouping on this stream to receive the message.
- 
emitDirect
- 
flushpublic abstract void flush()Flush any buffered tuples (when batching is enabled).
- 
reportError
 
-