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 SummaryMethods inherited from class org.apache.storm.task.OutputCollectorack, emit, emit, emit, emit, emit, emitDirect, emitDirect, emitDirect, emitDirect, emitDirect, fail, flush, reportError, resetTimeout
- 
Method Details- 
emitDescription copied from class:OutputCollectorEmits 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:
- emitin class- OutputCollector
- Parameters:
- streamId- the stream to emit to
- tuple- the new output tuple from this bolt
- Returns:
- the list of task ids that this new tuple was sent to
 
- 
emitDirectDescription copied from class:OutputCollectorEmits 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:
- emitDirectin class- OutputCollector
- Parameters:
- taskId- the taskId to send the new tuple to
- streamId- 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
 
 
-