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
org.apache.flink.state.api.input.splits
org.apache.flink.state.api.runtime
org.apache.flink.streaming.api.operators

Uses of PrioritizedOperatorSubtaskState in org.apache.flink.runtime.checkpoint

Methods in org.apache.flink.runtime.checkpoint that return PrioritizedOperatorSubtaskState

Modifier and Type	Method and Description
PrioritizedOperatorSubtaskState	PrioritizedOperatorSubtaskState.Builder.build()
static PrioritizedOperatorSubtaskState	PrioritizedOperatorSubtaskState.emptyNotRestored() Returns an empty PrioritizedOperatorSubtaskState singleton 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 and Description
PrioritizedOperatorSubtaskState	TaskStateManagerImpl.prioritizedOperatorState(OperatorID operatorID)
PrioritizedOperatorSubtaskState	TaskStateManager.prioritizedOperatorState(OperatorID operatorID) Returns means to restore previously reported state of an operator running in the owning task.

Uses of PrioritizedOperatorSubtaskState in org.apache.flink.state.api.input.splits

Methods in org.apache.flink.state.api.input.splits that return PrioritizedOperatorSubtaskState

Modifier and Type	Method and Description
PrioritizedOperatorSubtaskState	KeyGroupRangeInputSplit.getPrioritizedOperatorSubtaskState()

Uses of PrioritizedOperatorSubtaskState in org.apache.flink.state.api.runtime

Methods in org.apache.flink.state.api.runtime with parameters of type PrioritizedOperatorSubtaskState

Modifier and Type	Method and Description
SavepointEnvironment.Builder	SavepointEnvironment.Builder.setPrioritizedOperatorSubtaskState(PrioritizedOperatorSubtaskState prioritizedOperatorSubtaskState)

Uses of PrioritizedOperatorSubtaskState in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators with parameters of type PrioritizedOperatorSubtaskState

Modifier and Type	Method and Description
protected <K> AbstractKeyedStateBackend<K>	StreamTaskStateInitializerImpl.keyedStatedBackend(TypeSerializer<K> keySerializer, String operatorIdentifierText, PrioritizedOperatorSubtaskState prioritizedOperatorSubtaskStates, CloseableRegistry backendCloseableRegistry, MetricGroup metricGroup)
protected OperatorStateBackend	StreamTaskStateInitializerImpl.operatorStateBackend(String operatorIdentifierText, PrioritizedOperatorSubtaskState prioritizedOperatorSubtaskStates, CloseableRegistry backendCloseableRegistry)