Uses of Class
org.apache.storm.spout.CheckPointState.Action

Packages that use CheckPointState.Action

Package	Description
org.apache.storm.spout
org.apache.storm.topology

Uses of CheckPointState.Action in org.apache.storm.spout

Methods in org.apache.storm.spout that return CheckPointState.Action

Modifier and Type	Method and Description
CheckPointState.Action	CheckPointState.nextAction(boolean recovering) Get the next action to perform based on this checkpoint state.
static CheckPointState.Action	CheckPointState.Action.valueOf(String name) 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

Methods in org.apache.storm.topology with parameters of type CheckPointState.Action

Modifier and Type	Method and Description
protected void	StatefulBoltExecutor.handleCheckpoint(Tuple checkpointTuple, CheckPointState.Action action, long txid)
protected 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.