Package org.apache.storm.topology
Class BaseStatefulBoltExecutor.AnchoringOutputCollector
java.lang.Object
org.apache.storm.task.OutputCollector
org.apache.storm.topology.BaseStatefulBoltExecutor.AnchoringOutputCollector
- All Implemented Interfaces:
IErrorReporter
,IOutputCollector
- Enclosing class:
- BaseStatefulBoltExecutor
-
Method Summary
Methods inherited from class org.apache.storm.task.OutputCollector
ack, emit, emit, emit, emit, emit, emitDirect, emitDirect, emitDirect, emitDirect, emitDirect, fail, flush, reportError, resetTimeout
-
Method Details
-
emit
Description copied from class:OutputCollector
Emits a new unanchored tuple to the specified stream. Because it's unanchored, if a failure happens downstream, this new tuple won't affect whether any spout tuples are considered failed or not. The emitted values must be immutable.- Overrides:
emit
in classOutputCollector
- Parameters:
streamId
- the stream to emit totuple
- the new output tuple from this bolt- Returns:
- the list of task ids that this new tuple was sent to
-
emitDirect
Description copied from class:OutputCollector
Emits a tuple directly to the specified task id on the specified stream. If the target bolt does not subscribe to this bolt using a direct grouping, the tuple will not be sent. If the specified output stream is not declared as direct, or the target bolt subscribes with a non-direct grouping, an error will occur at runtime. Note that this method does not use anchors, so downstream failures won't affect the failure status of any spout tuples. The emitted values must be immutable.- Overrides:
emitDirect
in classOutputCollector
- Parameters:
taskId
- the taskId to send the new tuple tostreamId
- the stream to send the tuple on. It must be declared as a direct stream in the topology definition.tuple
- the new output tuple from this bolt
-