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

Packages that use OperatorSubtaskState

Package	Description
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.checkpoint.metadata
org.apache.flink.state.api.output
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	OperatorSubtaskState.Builder.build()
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, org.apache.flink.runtime.checkpoint.TaskStateAssignment assignment)
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.

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

Modifier and Type	Method and Description
static <T extends StateObject> void	StateAssignmentOperation.reDistributePartitionableStates(Map<OperatorID,OperatorState> oldOperatorStates, int newParallelism, java.util.function.Function<OperatorSubtaskState,StateObjectCollection<T>> extractHandle, OperatorStateRepartitioner<T> stateRepartitioner, Map<OperatorInstanceID,List<T>> result)

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.runtime.checkpoint.metadata

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

Modifier and Type	Method and Description
protected OperatorSubtaskState	MetadataV2Serializer.deserializeSubtaskState(DataInputStream dis, MetadataV2V3SerializerBase.DeserializationContext context)
protected OperatorSubtaskState	MetadataV2V3SerializerBase.deserializeSubtaskState(DataInputStream dis, MetadataV2V3SerializerBase.DeserializationContext context)

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

Modifier and Type	Method and Description
protected void	MetadataV3Serializer.serializeSubtaskState(OperatorSubtaskState subtaskState, DataOutputStream dos)
protected void	MetadataV2Serializer.serializeSubtaskState(OperatorSubtaskState subtaskState, DataOutputStream dos)
protected void	MetadataV2V3SerializerBase.serializeSubtaskState(OperatorSubtaskState subtaskState, DataOutputStream dos)

Uses of OperatorSubtaskState in org.apache.flink.state.api.output

Fields in org.apache.flink.state.api.output declared as OperatorSubtaskState

Modifier and Type	Field and Description
OperatorSubtaskState	TaggedOperatorSubtaskState.state

Constructors in org.apache.flink.state.api.output with parameters of type OperatorSubtaskState

Constructor and Description
TaggedOperatorSubtaskState(int index, OperatorSubtaskState state)

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()