Uses of Class
org.apache.flink.runtime.checkpoint.OperatorSubtaskState

Packages that use OperatorSubtaskState

Package	Description
org.apache.flink.runtime.checkpoint
org.apache.flink.streaming.api.operators

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

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

Modifier and Type	Method and Description
OperatorSubtaskState	OperatorState.getState(int subtaskIndex)
OperatorSubtaskState	TaskStateSnapshot.getSubtaskStateByOperatorID(OperatorID operatorID) Returns the subtask state for the given operator id (or null if not contained).
static OperatorSubtaskState	StateAssignmentOperation.operatorSubtaskStateFrom(OperatorInstanceID instanceID, Map<OperatorInstanceID,List<OperatorStateHandle>> subManagedOperatorState, Map<OperatorInstanceID,List<OperatorStateHandle>> subRawOperatorState, Map<OperatorInstanceID,List<KeyedStateHandle>> subManagedKeyedState, Map<OperatorInstanceID,List<KeyedStateHandle>> subRawKeyedState)
OperatorSubtaskState	TaskStateSnapshot.putSubtaskStateByOperatorID(OperatorID operatorID, OperatorSubtaskState state) Maps the given operator id to the given subtask state.

Methods in org.apache.flink.runtime.checkpoint that return types with arguments of type OperatorSubtaskState

Modifier and Type	Method and Description
Collection<OperatorSubtaskState>	OperatorState.getStates()
Set<Map.Entry<OperatorID,OperatorSubtaskState>>	TaskStateSnapshot.getSubtaskStateMappings() Returns the set of all mappings from operator id to the corresponding subtask state.
Map<Integer,OperatorSubtaskState>	OperatorState.getSubtaskStates()

Methods in org.apache.flink.runtime.checkpoint with parameters of type OperatorSubtaskState

Modifier and Type	Method and Description
void	OperatorState.putState(int subtaskIndex, OperatorSubtaskState subtaskState)
OperatorSubtaskState	TaskStateSnapshot.putSubtaskStateByOperatorID(OperatorID operatorID, OperatorSubtaskState state) Maps the given operator id to the given subtask state.

Constructors in org.apache.flink.runtime.checkpoint with parameters of type OperatorSubtaskState

Constructor and Description
Builder(OperatorSubtaskState jobManagerState, List<OperatorSubtaskState> alternativesByPriority)
Builder(OperatorSubtaskState jobManagerState, List<OperatorSubtaskState> alternativesByPriority, boolean restored)

Constructor parameters in org.apache.flink.runtime.checkpoint with type arguments of type OperatorSubtaskState

Constructor and Description
Builder(OperatorSubtaskState jobManagerState, List<OperatorSubtaskState> alternativesByPriority)
Builder(OperatorSubtaskState jobManagerState, List<OperatorSubtaskState> alternativesByPriority, boolean restored)
TaskStateSnapshot(Map<OperatorID,OperatorSubtaskState> subtaskStatesByOperatorID)

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

Methods in org.apache.flink.streaming.api.operators that return OperatorSubtaskState

Modifier and Type	Method and Description
OperatorSubtaskState	OperatorSnapshotFinalizer.getJobManagerOwnedState()
OperatorSubtaskState	OperatorSnapshotFinalizer.getTaskLocalState()