backtype.storm.topology

Class BasicOutputCollector

java.lang.Object

backtype.storm.topology.BasicOutputCollector

All Implemented Interfaces:

IBasicOutputCollector

public class BasicOutputCollector
extends Object
implements IBasicOutputCollector

Constructor Summary

Constructors

Constructor and Description
BasicOutputCollector(OutputCollector out)

Method Summary

Methods

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

Specified by:

emit in interface IBasicOutputCollector

emit

public List<Integer> emit(List<Object> tuple)

setContext

public void setContext(Tuple inputTuple)

emitDirect

public void emitDirect(int taskId,
              String streamId,
              List<Object> tuple)

Specified by:

emitDirect in interface IBasicOutputCollector

emitDirect

public void emitDirect(int taskId,
              List<Object> tuple)

getOutputter

protected IOutputCollector getOutputter()

reportError

public void reportError(Throwable t)

Specified by:

reportError in interface IBasicOutputCollector