org.apache.storm.topology

Class BasicOutputCollector

java.lang.Object

org.apache.storm.topology.BasicOutputCollector

All Implemented Interfaces:

IBasicOutputCollector

public class BasicOutputCollector
extends java.lang.Object
implements IBasicOutputCollector

Constructor Summary

Constructors

Constructor and Description
BasicOutputCollector(OutputCollector outputCollector, java.lang.String defaultEdge)

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.lang.String streamId, java.util.List<java.lang.Object> tuple)
void	reportError(java.lang.Throwable t)

Methods inherited from class java.lang.Object

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

Constructor Detail

BasicOutputCollector

public BasicOutputCollector(OutputCollector outputCollector,
                            java.lang.String defaultEdge)

Method Detail

emit

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

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

emitDirect

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

Specified by:

emitDirect in interface IBasicOutputCollector

reportError

public void reportError(java.lang.Throwable t)

Specified by:

reportError in interface IBasicOutputCollector