Uses of Class
org.apache.flink.runtime.checkpoint.PrioritizedOperatorSubtaskState
-
Packages that use PrioritizedOperatorSubtaskState Package Description org.apache.flink.runtime.checkpoint org.apache.flink.runtime.state -
-
Uses of PrioritizedOperatorSubtaskState in org.apache.flink.runtime.checkpoint
Methods in org.apache.flink.runtime.checkpoint that return PrioritizedOperatorSubtaskState Modifier and Type Method Description PrioritizedOperatorSubtaskStatePrioritizedOperatorSubtaskState.Builder. build()static PrioritizedOperatorSubtaskStatePrioritizedOperatorSubtaskState. empty(long restoredCheckpointId)static PrioritizedOperatorSubtaskStatePrioritizedOperatorSubtaskState. emptyNotRestored()Returns an emptyPrioritizedOperatorSubtaskStatesingleton for an empty, not-restored operator state. -
Uses of PrioritizedOperatorSubtaskState in org.apache.flink.runtime.state
Methods in org.apache.flink.runtime.state that return PrioritizedOperatorSubtaskState Modifier and Type Method Description PrioritizedOperatorSubtaskStateTaskStateManager. prioritizedOperatorState(OperatorID operatorID)Returns means to restore previously reported state of an operator running in the owning task.PrioritizedOperatorSubtaskStateTaskStateManagerImpl. prioritizedOperatorState(OperatorID operatorID)
-