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, 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. from a task-local source.

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, 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. from a task-local source.
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, 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, 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. from a task-local source.

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)