Uses of Enum Class
org.apache.storm.spout.CheckPointState.Action
Packages that use CheckPointState.Action
-
Uses of CheckPointState.Action in org.apache.storm.spout
Methods in org.apache.storm.spout that return CheckPointState.ActionModifier and TypeMethodDescriptionCheckPointState.nextAction(boolean recovering) Get the next action to perform based on this checkpoint state.static CheckPointState.ActionReturns the enum constant of this class with the specified name.static CheckPointState.Action[]CheckPointState.Action.values()Returns an array containing the constants of this enum class, in the order they are declared. -
Uses of CheckPointState.Action in org.apache.storm.topology
Methods in org.apache.storm.topology with parameters of type CheckPointState.ActionModifier and TypeMethodDescriptionprotected abstract voidBaseStatefulBoltExecutor.handleCheckpoint(Tuple checkpointTuple, CheckPointState.Action action, long txid) Sub-classes can implement the logic for handling checkpoint tuple.protected voidCheckpointTupleForwarder.handleCheckpoint(Tuple checkpointTuple, CheckPointState.Action action, long txid) Forwards the checkpoint tuple downstream.protected voidStatefulBoltExecutor.handleCheckpoint(Tuple checkpointTuple, CheckPointState.Action action, long txid)