Package org.apache.storm.executor.bolt
Class BoltOutputCollectorImpl
java.lang.Object
org.apache.storm.executor.bolt.BoltOutputCollectorImpl
- All Implemented Interfaces:
IErrorReporter,IOutputCollector
-
Constructor Summary
ConstructorsConstructorDescriptionBoltOutputCollectorImpl(BoltExecutor executor, Task taskData, Random random, boolean isEventLoggers, boolean ackingEnabled, boolean isDebug) -
Method Summary
Modifier and TypeMethodDescriptionvoidReturns the task ids that received the tuples.voidemitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple) voidvoidflush()voidreportError(Throwable error) voidresetTimeout(Tuple input)
-
Constructor Details
-
BoltOutputCollectorImpl
public BoltOutputCollectorImpl(BoltExecutor executor, Task taskData, Random random, boolean isEventLoggers, boolean ackingEnabled, boolean isDebug)
-
-
Method Details
-
emit
Description copied from interface:IOutputCollectorReturns the task ids that received the tuples.- Specified by:
emitin interfaceIOutputCollector
-
emitDirect
- Specified by:
emitDirectin interfaceIOutputCollector
-
ack
- Specified by:
ackin interfaceIOutputCollector
-
fail
- Specified by:
failin interfaceIOutputCollector
-
resetTimeout
- Specified by:
resetTimeoutin interfaceIOutputCollector
-
flush
public void flush()- Specified by:
flushin interfaceIOutputCollector
-
reportError
- Specified by:
reportErrorin interfaceIErrorReporter
-