Package | Description |
---|---|
org.apache.storm.topology |
Modifier and Type | Class and Description |
---|---|
class |
CheckpointTupleForwarder
Wraps
IRichBolt and forwards checkpoint tuples in a stateful topology. |
class |
StatefulBoltExecutor<T extends State>
Wraps a
IStatefulBolt and manages the state of the bolt. |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.