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
ConstructorDescriptionSpoutOutputCollectorImpl
(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.void
emitDirect
(int taskId, String streamId, List<Object> tuple, Object messageId) void
flush()
long
void
reportError
(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:ISpoutOutputCollector
Returns the task ids that received the tuples.- Specified by:
emit
in interfaceISpoutOutputCollector
-
emitDirect
- Specified by:
emitDirect
in interfaceISpoutOutputCollector
-
flush
public void flush()- Specified by:
flush
in interfaceISpoutOutputCollector
-
getPendingCount
public long getPendingCount()- Specified by:
getPendingCount
in interfaceISpoutOutputCollector
-
reportError
- Specified by:
reportError
in interfaceIErrorReporter
-