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

Packages that use OperatorState

Package	Description
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.checkpoint.metadata
org.apache.flink.state.api.input
org.apache.flink.state.api.output
org.apache.flink.state.api.runtime.metadata

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

Subclasses of OperatorState in org.apache.flink.runtime.checkpoint

Modifier and Type	Class and Description
class	FullyFinishedOperatorState A special operator state implementation representing the operators whose instances are all finished.

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

Modifier and Type	Method and Description
OperatorState	OperatorState.copyAndDiscardInFlightData()
OperatorState	FullyFinishedOperatorState.copyAndDiscardInFlightData()

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

Modifier and Type	Method and Description
Map<OperatorID,OperatorState>	CompletedCheckpoint.getOperatorStates()
Map<OperatorID,OperatorState>	PendingCheckpoint.getOperatorStates()

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

Modifier and Type	Method and Description
static List<KeyedStateHandle>	StateAssignmentOperation.getManagedKeyedStateHandles(OperatorState operatorState, KeyGroupRange subtaskKeyGroupRange) Collect managedKeyedStateHandles which have intersection with given KeyGroupRange from operatorState.
static List<KeyedStateHandle>	StateAssignmentOperation.getRawKeyedStateHandles(OperatorState operatorState, KeyGroupRange subtaskKeyGroupRange) Collect rawKeyedStateHandles which have intersection with given KeyGroupRange from operatorState.

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

Modifier and Type	Method and Description
void	DefaultCheckpointPlan.fulfillFinishedTaskStatus(Map<OperatorID,OperatorState> operatorStates)
void	FinishedTaskStateProvider.fulfillFinishedTaskStatus(Map<OperatorID,OperatorState> operatorStates) Fulfills the state for the finished subtasks and operators to indicate they are finished.
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)

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

Constructor and Description
CheckpointCoordinator(JobID job, CheckpointCoordinatorConfiguration chkConfig, Collection<OperatorCoordinatorCheckpointContext> coordinatorsToCheckpoint, CheckpointIDCounter checkpointIDCounter, CompletedCheckpointStore completedCheckpointStore, CheckpointStorage checkpointStorage, Executor executor, CheckpointsCleaner checkpointsCleaner, ScheduledExecutor timer, CheckpointFailureManager failureManager, CheckpointPlanCalculator checkpointPlanCalculator, ExecutionAttemptMappingProvider attemptMappingProvider, Clock clock, CheckpointStatsTracker statsTracker, java.util.function.BiFunction<Set<ExecutionJobVertex>,Map<OperatorID,OperatorState>,VertexFinishedStateChecker> vertexFinishedStateCheckerFactory)
CompletedCheckpoint(JobID job, long checkpointID, long timestamp, long completionTimestamp, Map<OperatorID,OperatorState> operatorStates, Collection<MasterState> masterHookStates, CheckpointProperties props, CompletedCheckpointStorageLocation storageLocation, CompletedCheckpointStats completedCheckpointStats)
CompletedCheckpoint(JobID job, long checkpointID, long timestamp, long completionTimestamp, Map<OperatorID,OperatorState> operatorStates, Collection<MasterState> masterHookStates, CheckpointProperties props, CompletedCheckpointStorageLocation storageLocation, CompletedCheckpointStats completedCheckpointStats, CheckpointProperties restoredProps)
StateAssignmentOperation(long restoreCheckpointId, Set<ExecutionJobVertex> tasks, Map<OperatorID,OperatorState> operatorStates, boolean allowNonRestoredState)
VertexFinishedStateChecker(Set<ExecutionJobVertex> vertices, Map<OperatorID,OperatorState> operatorStates)

Uses of OperatorState in org.apache.flink.runtime.checkpoint.metadata

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

Modifier and Type	Method and Description
protected abstract OperatorState	MetadataV2V3SerializerBase.deserializeOperatorState(DataInputStream dis, MetadataV2V3SerializerBase.DeserializationContext context)
protected OperatorState	MetadataV2Serializer.deserializeOperatorState(DataInputStream dis, MetadataV2V3SerializerBase.DeserializationContext context)
protected OperatorState	MetadataV3Serializer.deserializeOperatorState(DataInputStream dis, MetadataV2V3SerializerBase.DeserializationContext context)

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

Modifier and Type	Method and Description
Collection<OperatorState>	CheckpointMetadata.getOperatorStates()

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

Modifier and Type	Method and Description
protected abstract void	MetadataV2V3SerializerBase.serializeOperatorState(OperatorState operatorState, DataOutputStream dos)
protected void	MetadataV2Serializer.serializeOperatorState(OperatorState operatorState, DataOutputStream dos)
protected void	MetadataV3Serializer.serializeOperatorState(OperatorState operatorState, DataOutputStream dos)

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

Constructor and Description
CheckpointMetadata(long checkpointId, Collection<OperatorState> operatorStates, Collection<MasterState> masterStates)
CheckpointMetadata(long checkpointId, Collection<OperatorState> operatorStates, Collection<MasterState> masterStates, CheckpointProperties properties)

Uses of OperatorState in org.apache.flink.state.api.input

Constructors in org.apache.flink.state.api.input with parameters of type OperatorState

Constructor and Description
BroadcastStateInputFormat(OperatorState operatorState, Configuration configuration, StateBackend backend, MapStateDescriptor<K,V> descriptor) Creates an input format for reading broadcast state from an operator in a savepoint.
KeyedStateInputFormat(OperatorState operatorState, StateBackend stateBackend, Configuration configuration, StateReaderOperator<?,K,N,OUT> operator) Creates an input format for reading partitioned state from an operator in a savepoint.
ListStateInputFormat(OperatorState operatorState, Configuration configuration, StateBackend backend, ListStateDescriptor<OT> descriptor) Creates an input format for reading list state from an operator in a savepoint.
UnionStateInputFormat(OperatorState operatorState, Configuration configuration, StateBackend backend, ListStateDescriptor<OT> descriptor) Creates an input format for reading union state from an operator in a savepoint.

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

Methods in org.apache.flink.state.api.output with parameters of type OperatorState

Modifier and Type	Method and Description
void	StatePathExtractor.flatMap(OperatorState operatorState, Collector<Path> out)

Method parameters in org.apache.flink.state.api.output with type arguments of type OperatorState

Modifier and Type	Method and Description
void	MergeOperatorStates.reduce(Iterable<OperatorState> values, Collector<CheckpointMetadata> out)
void	OperatorSubtaskStateReducer.reduce(Iterable<TaggedOperatorSubtaskState> values, Collector<OperatorState> out)

Uses of OperatorState in org.apache.flink.state.api.runtime.metadata

Methods in org.apache.flink.state.api.runtime.metadata that return OperatorState

Modifier and Type	Method and Description
OperatorState	SavepointMetadataV2.getOperatorState(String uid)
OperatorState	SavepointMetadata.getOperatorState(String uid) Deprecated.

Methods in org.apache.flink.state.api.runtime.metadata that return types with arguments of type OperatorState

Modifier and Type	Method and Description
List<OperatorState>	SavepointMetadataV2.getExistingOperators()
List<OperatorState>	SavepointMetadata.getExistingOperators() Deprecated.

Constructor parameters in org.apache.flink.state.api.runtime.metadata with type arguments of type OperatorState

Constructor and Description
SavepointMetadata(int maxParallelism, Collection<MasterState> masterStates, Collection<OperatorState> initialStates) Deprecated.
SavepointMetadataV2(int maxParallelism, Collection<MasterState> masterStates, Collection<OperatorState> initialStates)