backtype.storm.coordination
Class BatchOutputCollector

java.lang.Object
  backtype.storm.coordination.BatchOutputCollector

Direct Known Subclasses:

BatchOutputCollectorImpl

public abstract class BatchOutputCollector
extends java.lang.Object

Constructor Summary

BatchOutputCollector()

Method Summary

java.util.List<java.lang.Integer>	emit(java.util.List<java.lang.Object> tuple) Emits a tuple to the default output stream.
abstract java.util.List<java.lang.Integer>	emit(java.lang.String streamId, java.util.List<java.lang.Object> tuple)
void	emitDirect(int taskId, java.util.List<java.lang.Object> tuple) Emits a tuple to the specified task on the default output stream.
abstract void	emitDirect(int taskId, java.lang.String streamId, java.util.List<java.lang.Object> tuple)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BatchOutputCollector

public BatchOutputCollector()

Method Detail

emit

public java.util.List<java.lang.Integer> emit(java.util.List<java.lang.Object> tuple)

Emits a tuple to the default output stream.

emit

public abstract java.util.List<java.lang.Integer> emit(java.lang.String streamId,
                                                       java.util.List<java.lang.Object> tuple)

emitDirect

public void emitDirect(int taskId,
                       java.util.List<java.lang.Object> tuple)

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

public abstract void emitDirect(int taskId,
                                java.lang.String streamId,
                                java.util.List<java.lang.Object> tuple)