public interface ICommitterTridentSpout<X> extends ITridentSpout<X>
Modifier and Type | Interface and Description |
---|---|
static interface |
ICommitterTridentSpout.Emitter |
ITridentSpout.BatchCoordinator<X>
Modifier and Type | Method and Description |
---|---|
ICommitterTridentSpout.Emitter |
getEmitter(String txStateId,
Map<String,Object> conf,
TopologyContext context)
The emitter for a TransactionalSpout runs as many tasks across the cluster.
|
getComponentConfiguration, getCoordinator, getOutputFields
ICommitterTridentSpout.Emitter getEmitter(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout
The emitter for a TransactionalSpout runs as many tasks across the cluster. Emitters are responsible for emitting batches of tuples for a transaction and must ensure that the same batch of tuples is always emitted for the same transaction id.
All emitter tasks get the same transaction metadata. The topology context parameter contains the instance task id that can be used to distribute the work across the tasks.
getEmitter
in interface ITridentSpout<X>
txStateId
- stream idconf
- Storm config mapcontext
- topology contextCopyright © 2022 The Apache Software Foundation. All rights reserved.