backtype.storm.topology

Class BasicOutputCollector

java.lang.Object

backtype.storm.topology.BasicOutputCollector

All Implemented Interfaces:

IBasicOutputCollector

public class BasicOutputCollector
extends java.lang.Object
implements IBasicOutputCollector

Constructor Summary

Constructors

Constructor and Description
BasicOutputCollector(OutputCollector out)

Method Summary

Modifier and Type	Method and Description
java.util.List<java.lang.Integer>	emit(java.util.List<java.lang.Object> tuple)
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)
void	emitDirect(int taskId, java.lang.String streamId, java.util.List<java.lang.Object> tuple)
protected IOutputCollector	getOutputter()
void	reportError(java.lang.Throwable t)
void	setContext(Tuple anInputTuple)

Methods inherited from class java.lang.Object

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

Constructor Detail

BasicOutputCollector

public BasicOutputCollector(OutputCollector out)

Method Detail

emit

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

Specified by:

emit in interface IBasicOutputCollector

emit

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

setContext

public void setContext(Tuple anInputTuple)

emitDirect

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

Specified by:

emitDirect in interface IBasicOutputCollector

emitDirect

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

getOutputter

protected IOutputCollector getOutputter()

reportError

public void reportError(java.lang.Throwable t)

Specified by:

reportError in interface IBasicOutputCollector