backtype.storm.task
Interface IOutputCollector

All Known Implementing Classes:

CoordinatedBolt.CoordinatedOutputCollector, OutputCollector, TridentBoltExecutor.CoordinatedOutputCollector

public interface IOutputCollector

Method Summary

void	ack(Tuple input)
java.util.List<java.lang.Integer>	emit(java.lang.String streamId, java.util.Collection<Tuple> anchors, java.util.List<java.lang.Object> tuple) Returns the task ids that received the tuples.
void	emitDirect(int taskId, java.lang.String streamId, java.util.Collection<Tuple> anchors, java.util.List<java.lang.Object> tuple)
void	fail(Tuple input)
void	reportError(java.lang.Throwable error)

Method Detail

emit

java.util.List<java.lang.Integer> emit(java.lang.String streamId,
                                       java.util.Collection<Tuple> anchors,
                                       java.util.List<java.lang.Object> tuple)

Returns the task ids that received the tuples.

emitDirect

void emitDirect(int taskId,
                java.lang.String streamId,
                java.util.Collection<Tuple> anchors,
                java.util.List<java.lang.Object> tuple)

ack

void ack(Tuple input)

fail

void fail(Tuple input)

reportError

void reportError(java.lang.Throwable error)