backtype.storm.task

Class OutputCollectorImpl

java.lang.Object

backtype.storm.task.OutputCollector

backtype.storm.task.OutputCollectorImpl

All Implemented Interfaces:

IErrorReporter, IOutputCollector

public class OutputCollectorImpl
extends OutputCollector

This output collector exposes the API for emitting tuples from an IRichBolt. This is the core API for emitting tuples. For a simpler API, and a more restricted form of stream processing, see IBasicBolt and BasicOutputCollector.

Constructor Summary

Constructors

Constructor and Description
OutputCollectorImpl(OutputCollector delegate)

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.
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)

Methods inherited from class backtype.storm.task.OutputCollector

emit, emit, emit, emit, emit, emitDirect, emitDirect, emitDirect, emitDirect, emitDirect

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputCollectorImpl

public OutputCollectorImpl(OutputCollector delegate)

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

Overrides:

emit in class OutputCollector

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

Overrides:

emitDirect in class OutputCollector

ack

public void ack(Tuple input)

Specified by:

ack in interface IOutputCollector

Overrides:

ack in class OutputCollector

fail

public void fail(Tuple input)

Specified by:

fail in interface IOutputCollector

Overrides:

fail in class OutputCollector

reportError

public void reportError(java.lang.Throwable error)

Specified by:

reportError in interface IErrorReporter

Overrides:

reportError in class OutputCollector