public interface IStatefulBolt<T extends State> extends IStatefulComponent<T>
A bolt abstraction for supporting stateful computation. The state of the bolt is periodically checkpointed.
The framework provides at-least once guarantee for the state updates. The stateful bolts are expected to anchor the tuples while emitting and ack the input tuples once its processed.
Modifier and Type | Method and Description |
---|---|
void |
cleanup()
Analogue to bolt function.
|
void |
execute(Tuple input)
Analogue to bolt function.
|
void |
prepare(Map<String,Object> topoConf,
TopologyContext context,
OutputCollector collector)
Analogue to bolt function.
|
initState, preCommit, prePrepare, preRollback
declareOutputFields, getComponentConfiguration
void prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
Analogue to bolt function.
void execute(Tuple input)
Analogue to bolt function.
IBolt.execute(Tuple)
void cleanup()
Analogue to bolt function.
IBolt.cleanup()
Copyright © 2022 The Apache Software Foundation. All rights reserved.