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

BasicOutputCollector(OutputCollector out)

Method Summary

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)
IOutputCollector	getOutputter()
void	setContext(Tuple inputTuple)

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

getOutputter

public IOutputCollector getOutputter()

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)