Uses of Enum
org.apache.storm.spout.CheckPointState.Action
-
Uses of CheckPointState.Action in org.apache.storm.spout
Modifier and TypeMethodDescriptionCheckPointState.nextAction
(boolean recovering) Get the next action to perform based on this checkpoint state.static CheckPointState.Action
Returns the enum constant of this type with the specified name.static CheckPointState.Action[]
CheckPointState.Action.values()
Returns an array containing the constants of this enum type, in the order they are declared. -
Uses of CheckPointState.Action in org.apache.storm.topology
Modifier and TypeMethodDescriptionprotected abstract void
BaseStatefulBoltExecutor.handleCheckpoint
(Tuple checkpointTuple, CheckPointState.Action action, long txid) Sub-classes can implement the logic for handling checkpoint tuple.protected void
CheckpointTupleForwarder.handleCheckpoint
(Tuple checkpointTuple, CheckPointState.Action action, long txid) Forwards the checkpoint tuple downstream.protected void
StatefulBoltExecutor.handleCheckpoint
(Tuple checkpointTuple, CheckPointState.Action action, long txid)