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
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)
|
protected IOutputCollector |
getOutputter()
|
void |
reportError(java.lang.Throwable t)
|
void |
setContext(Tuple inputTuple)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
BasicOutputCollector
public BasicOutputCollector(OutputCollector out)
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)
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