Package org.apache.storm.coordination
Class BatchOutputCollector
java.lang.Object
org.apache.storm.coordination.BatchOutputCollector
- Direct Known Subclasses:
BatchOutputCollectorImpl
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionEmits a tuple to the default output stream.abstract void
emitDirect
(int taskId, String streamId, List<Object> tuple) void
emitDirect
(int taskId, List<Object> tuple) Emits a tuple to the specified task on the default output stream.abstract void
flush()
Flush any buffered tuples (when batching is enabled).abstract void
reportError
(Throwable error)
-
Constructor Details
-
BatchOutputCollector
public BatchOutputCollector()
-
-
Method Details
-
emit
Emits a tuple to the default output stream. -
emit
-
emitDirect
Emits 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
-
flush
public abstract void flush()Flush any buffered tuples (when batching is enabled). -
reportError
-