Package org.apache.storm.executor.spout
Class SpoutOutputCollectorImpl
java.lang.Object
org.apache.storm.executor.spout.SpoutOutputCollectorImpl
- All Implemented Interfaces:
ISpoutOutputCollector,IErrorReporter
Methods are not thread safe. Each thread expected to have a separate instance, or else synchronize externally
-
Constructor Summary
ConstructorsConstructorDescriptionSpoutOutputCollectorImpl(ISpout spout, SpoutExecutor executor, Task taskData, MutableLong emittedCount, boolean hasAckers, Random random, Boolean isEventLoggers, Boolean isDebug, RotatingMap<Long, TupleInfo> pending) -
Method Summary
Modifier and TypeMethodDescriptionReturns the task ids that received the tuples.voidemitDirect(int taskId, String streamId, List<Object> tuple, Object messageId) voidflush()longvoidreportError(Throwable error)
-
Constructor Details
-
SpoutOutputCollectorImpl
public SpoutOutputCollectorImpl(ISpout spout, SpoutExecutor executor, Task taskData, MutableLong emittedCount, boolean hasAckers, Random random, Boolean isEventLoggers, Boolean isDebug, RotatingMap<Long, TupleInfo> pending)
-
-
Method Details
-
emit
Description copied from interface:ISpoutOutputCollectorReturns the task ids that received the tuples.- Specified by:
emitin interfaceISpoutOutputCollector
-
emitDirect
- Specified by:
emitDirectin interfaceISpoutOutputCollector
-
flush
public void flush()- Specified by:
flushin interfaceISpoutOutputCollector
-
getPendingCount
public long getPendingCount()- Specified by:
getPendingCountin interfaceISpoutOutputCollector
-
reportError
- Specified by:
reportErrorin interfaceIErrorReporter
-