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

Packages that use StateObjectCollection

Package	Description
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.checkpoint.metadata

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

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

Modifier and Type	Method	Description
static <T extends StateObject> StateObjectCollection<T>	StateObjectCollection.empty()
static <T extends StateObject> StateObjectCollection<T>	StateObjectCollection.emptyIfNull(StateObjectCollection<T> collection)
StateObjectCollection<InputChannelStateHandle>	OperatorSubtaskState.getInputChannelState()
StateObjectCollection<KeyedStateHandle>	PrioritizedOperatorSubtaskState.getJobManagerManagedKeyedState()	Returns the managed keyed state from the job manager, which represents the ground truth about what this state should represent.
StateObjectCollection<OperatorStateHandle>	PrioritizedOperatorSubtaskState.getJobManagerManagedOperatorState()	Returns the managed operator state from the job manager, which represents the ground truth about what this state should represent.
StateObjectCollection<KeyedStateHandle>	PrioritizedOperatorSubtaskState.getJobManagerRawKeyedState()	Returns the raw keyed state from the job manager, which represents the ground truth about what this state should represent.
StateObjectCollection<OperatorStateHandle>	PrioritizedOperatorSubtaskState.getJobManagerRawOperatorState()	Returns the raw operator state from the job manager, which represents the ground truth about what this state should represent.
StateObjectCollection<KeyedStateHandle>	OperatorSubtaskState.getManagedKeyedState()
StateObjectCollection<OperatorStateHandle>	OperatorSubtaskState.getManagedOperatorState()
StateObjectCollection<InputChannelStateHandle>	PrioritizedOperatorSubtaskState.getPrioritizedInputChannelState()
StateObjectCollection<ResultSubpartitionStateHandle>	PrioritizedOperatorSubtaskState.getPrioritizedResultSubpartitionState()
StateObjectCollection<KeyedStateHandle>	OperatorSubtaskState.getRawKeyedState()
StateObjectCollection<OperatorStateHandle>	OperatorSubtaskState.getRawOperatorState()
StateObjectCollection<ResultSubpartitionStateHandle>	OperatorSubtaskState.getResultSubpartitionState()
static <T extends StateObject> StateObjectCollection<T>	StateObjectCollection.singleton(T stateObject)
static <T extends StateObject> StateObjectCollection<T>	StateObjectCollection.singletonOrEmpty(T stateObject)

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

Modifier and Type	Method	Description
List<StateObjectCollection<KeyedStateHandle>>	PrioritizedOperatorSubtaskState.getPrioritizedManagedKeyedState()	Returns an immutable list with all alternative snapshots to restore the managed keyed state, in the order in which we should attempt to restore.
List<StateObjectCollection<OperatorStateHandle>>	PrioritizedOperatorSubtaskState.getPrioritizedManagedOperatorState()	Returns an immutable list with all alternative snapshots to restore the managed operator state, in the order in which we should attempt to restore.
List<StateObjectCollection<KeyedStateHandle>>	PrioritizedOperatorSubtaskState.getPrioritizedRawKeyedState()	Returns an immutable list with all alternative snapshots to restore the raw keyed state, in the order in which we should attempt to restore.
List<StateObjectCollection<OperatorStateHandle>>	PrioritizedOperatorSubtaskState.getPrioritizedRawOperatorState()	Returns an immutable list with all alternative snapshots to restore the raw operator state, in the order in which we should attempt to restore.
protected <T extends StateObject> List<StateObjectCollection<T>>	PrioritizedOperatorSubtaskState.Builder.resolvePrioritizedAlternatives(StateObjectCollection<T> jobManagerState, List<StateObjectCollection<T>> alternativesByPriority, java.util.function.BiFunction<T,T,Boolean> approveFun)	This helper method resolves the dependencies between the ground truth of the operator state obtained from the job manager and potential alternatives for recovery, e.g.

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

Modifier and Type	Method	Description
static <T extends StateObject> StateObjectCollection<T>	StateObjectCollection.emptyIfNull(StateObjectCollection<T> collection)
protected <T extends StateObject> List<StateObjectCollection<T>>	PrioritizedOperatorSubtaskState.Builder.resolvePrioritizedAlternatives(StateObjectCollection<T> jobManagerState, List<StateObjectCollection<T>> alternativesByPriority, java.util.function.BiFunction<T,T,Boolean> approveFun)	This helper method resolves the dependencies between the ground truth of the operator state obtained from the job manager and potential alternatives for recovery, e.g.
OperatorSubtaskState.Builder	OperatorSubtaskState.Builder.setInputChannelState(StateObjectCollection<InputChannelStateHandle> inputChannelState)
OperatorSubtaskState.Builder	OperatorSubtaskState.Builder.setManagedKeyedState(StateObjectCollection<KeyedStateHandle> managedKeyedState)
OperatorSubtaskState.Builder	OperatorSubtaskState.Builder.setManagedOperatorState(StateObjectCollection<OperatorStateHandle> managedOperatorState)
OperatorSubtaskState.Builder	OperatorSubtaskState.Builder.setRawKeyedState(StateObjectCollection<KeyedStateHandle> rawKeyedState)
OperatorSubtaskState.Builder	OperatorSubtaskState.Builder.setRawOperatorState(StateObjectCollection<OperatorStateHandle> rawOperatorState)
OperatorSubtaskState.Builder	OperatorSubtaskState.Builder.setResultSubpartitionState(StateObjectCollection<ResultSubpartitionStateHandle> resultSubpartitionState)

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

Modifier and Type	Method	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)
protected <T extends StateObject> List<StateObjectCollection<T>>	PrioritizedOperatorSubtaskState.Builder.resolvePrioritizedAlternatives(StateObjectCollection<T> jobManagerState, List<StateObjectCollection<T>> alternativesByPriority, java.util.function.BiFunction<T,T,Boolean> approveFun)	This helper method resolves the dependencies between the ground truth of the operator state obtained from the job manager and potential alternatives for recovery, e.g.

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

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

Modifier and Type	Method	Description
protected StateObjectCollection<InputChannelStateHandle>	MetadataV2V3SerializerBase.deserializeInputChannelStateHandle(DataInputStream dis, MetadataV2V3SerializerBase.DeserializationContext context)
static StateObjectCollection<InputChannelStateHandle>	MetadataV3Serializer.deserializeInputChannelStateHandle(DataInputStream dis)
StateObjectCollection<InputChannelStateHandle>	MetadataV3Serializer.deserializeInputChannelStateHandle(DataInputStream dis, MetadataV2V3SerializerBase.DeserializationContext context)
protected StateObjectCollection<ResultSubpartitionStateHandle>	MetadataV2V3SerializerBase.deserializeResultSubpartitionStateHandle(DataInputStream dis, MetadataV2V3SerializerBase.DeserializationContext context)
StateObjectCollection<ResultSubpartitionStateHandle>	MetadataV3Serializer.deserializeResultSubpartitionStateHandle(DataInputStream dis)
StateObjectCollection<ResultSubpartitionStateHandle>	MetadataV3Serializer.deserializeResultSubpartitionStateHandle(DataInputStream dis, MetadataV2V3SerializerBase.DeserializationContext context)