org.apache.storm.task

Interface IOutputCollector

All Superinterfaces:

IErrorReporter

All Known Implementing Classes:

BaseStatefulBoltExecutor.AnchoringOutputCollector, BoltOutputCollectorImpl, CoordinatedBolt.CoordinatedOutputCollector, OutputCollector

public interface IOutputCollector
extends IErrorReporter

Method Summary

Modifier and Type	Method and Description
void	ack(Tuple input)
List<Integer>	emit(String streamId, Collection<Tuple> anchors, List<Object> tuple) Returns the task ids that received the tuples.
void	emitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple)
void	fail(Tuple input)
void	flush()
void	resetTimeout(Tuple input)

Methods inherited from interface org.apache.storm.task.IErrorReporter

reportError

Method Detail

emit

List<Integer> emit(String streamId,
                   Collection<Tuple> anchors,
                   List<Object> tuple)

Returns the task ids that received the tuples.

emitDirect

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

ack

void ack(Tuple input)

fail

void fail(Tuple input)

resetTimeout

void resetTimeout(Tuple input)

flush

void flush()