org.apache.storm.task

Class OutputCollector

java.lang.Object

org.apache.storm.task.OutputCollector

All Implemented Interfaces:

IErrorReporter, IOutputCollector

public class OutputCollector
extends java.lang.Object
implements IOutputCollector

Constructor Summary

Constructors

Constructor and Description
OutputCollector(IOutputCollector listener)

Method Summary

Modifier and Type	Method and Description
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.
java.util.List<java.lang.Integer>	emit(java.lang.String streamId, java.util.List<java.lang.Object> tuple)
java.util.List<java.lang.Integer>	emit(java.lang.String streamId, Tuple anchor, java.util.List<java.lang.Object> tuple) Emits a new tuple to a specific stream with a single anchor.
void	emitDirect(int taskId, java.lang.String streamId, java.util.Collection<Tuple> anchors, java.util.List<java.lang.Object> tuple)
void	emitDirect(int taskId, java.lang.String streamId, java.util.List<java.lang.Object> tuple)
void	fail(Tuple input)
void	reportError(java.lang.Throwable error)

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputCollector

public OutputCollector(IOutputCollector listener)

Method Detail

emit

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

Description copied from interface: IOutputCollector

Returns the task ids that received the tuples.

Specified by:

emit in interface IOutputCollector

emit

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

Emits a new tuple to a specific stream with a single anchor. The emitted values must be immutable.

Parameters:

streamId - the stream to emit to

anchor - the tuple to anchor to

tuple - the new output tuple from this bolt

Returns:

the list of task ids that this new tuple was sent to

emit

public 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.lang.String streamId,
                       java.util.Collection<Tuple> anchors,
                       java.util.List<java.lang.Object> tuple)

Specified by:

emitDirect in interface IOutputCollector

emitDirect

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

ack

public void ack(Tuple input)

Specified by:

ack in interface IOutputCollector

fail

public void fail(Tuple input)

Specified by:

fail in interface IOutputCollector

reportError

public void reportError(java.lang.Throwable error)

Specified by:

reportError in interface IErrorReporter