Uses of Interface
org.apache.flink.runtime.state.KeyedStateHandle

Packages that use KeyedStateHandle

Package	Description
org.apache.flink.contrib.streaming.state
org.apache.flink.contrib.streaming.state.restore
org.apache.flink.contrib.streaming.state.snapshot
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.checkpoint.metadata
org.apache.flink.runtime.state
org.apache.flink.runtime.state.changelog
org.apache.flink.runtime.state.changelog.inmemory
org.apache.flink.runtime.state.filesystem
org.apache.flink.runtime.state.hashmap
org.apache.flink.runtime.state.heap	This package contains the classes for key/value state backends that store the state on the JVM heap as objects.
org.apache.flink.runtime.state.memory
org.apache.flink.runtime.state.restore
org.apache.flink.state.api.input.splits
org.apache.flink.state.changelog
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.sorted.state

Uses of KeyedStateHandle in org.apache.flink.contrib.streaming.state

Methods in org.apache.flink.contrib.streaming.state that return KeyedStateHandle

Modifier and Type	Method and Description
static KeyedStateHandle	RocksDBIncrementalCheckpointUtils.chooseTheBestStateHandleForInitial(Collection<KeyedStateHandle> restoreStateHandles, KeyGroupRange targetKeyGroupRange) Choose the best state handle according to the RocksDBIncrementalCheckpointUtils.STATE_HANDLE_EVALUATOR to init the initial db.

Methods in org.apache.flink.contrib.streaming.state that return types with arguments of type KeyedStateHandle

Modifier and Type	Method and Description
RunnableFuture<SnapshotResult<KeyedStateHandle>>	RocksDBKeyedStateBackend.snapshot(long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions) Triggers an asynchronous snapshot of the keyed state backend from RocksDB.

Method parameters in org.apache.flink.contrib.streaming.state with type arguments of type KeyedStateHandle

Modifier and Type	Method and Description
static KeyedStateHandle	RocksDBIncrementalCheckpointUtils.chooseTheBestStateHandleForInitial(Collection<KeyedStateHandle> restoreStateHandles, KeyGroupRange targetKeyGroupRange) Choose the best state handle according to the RocksDBIncrementalCheckpointUtils.STATE_HANDLE_EVALUATOR to init the initial db.
<K> AbstractKeyedStateBackend<K>	EmbeddedRocksDBStateBackend.createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry)
<K> AbstractKeyedStateBackend<K>	RocksDBStateBackend.createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry) Deprecated.
<K> AbstractKeyedStateBackend<K>	EmbeddedRocksDBStateBackend.createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry, double managedMemoryFraction)
<K> AbstractKeyedStateBackend<K>	RocksDBStateBackend.createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry, double managedMemoryFraction) Deprecated.

Constructor parameters in org.apache.flink.contrib.streaming.state with type arguments of type KeyedStateHandle

Constructor and Description

RocksDBKeyedStateBackendBuilder(String operatorIdentifier, ClassLoader userCodeClassLoader, File instanceBasePath, RocksDBResourceContainer optionsContainer, java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, TaskKvStateRegistry kvStateRegistry, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, ExecutionConfig executionConfig, LocalRecoveryConfig localRecoveryConfig, EmbeddedRocksDBStateBackend.PriorityQueueStateType priorityQueueStateType, TtlTimeProvider ttlTimeProvider, LatencyTrackingStateConfig latencyTrackingStateConfig, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, StreamCompressionDecorator keyGroupCompressionDecorator, CloseableRegistry cancelStreamRegistry)

Uses of KeyedStateHandle in org.apache.flink.contrib.streaming.state.restore

Constructor parameters in org.apache.flink.contrib.streaming.state.restore with type arguments of type KeyedStateHandle

Constructor and Description
RocksDBFullRestoreOperation(KeyGroupRange keyGroupRange, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, StateSerializerProvider<K> keySerializerProvider, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, Collection<KeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity)
RocksDBHeapTimersFullRestoreOperation(KeyGroupRange keyGroupRange, int numberOfKeyGroups, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, LinkedHashMap<String,HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, HeapPriorityQueueSetFactory priorityQueueFactory, StateSerializerProvider<K> keySerializerProvider, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, Collection<KeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity)
RocksDBIncrementalRestoreOperation(String operatorIdentifier, KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, int numberOfTransferringThreads, CloseableRegistry cancelStreamRegistry, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, StateSerializerProvider<K> keySerializerProvider, File instanceBasePath, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, MetricGroup metricGroup, Collection<KeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity)

Uses of KeyedStateHandle in org.apache.flink.contrib.streaming.state.snapshot

Methods in org.apache.flink.contrib.streaming.state.snapshot that return types with arguments of type KeyedStateHandle

Modifier and Type	Method and Description
SnapshotStrategy.SnapshotResultSupplier<KeyedStateHandle>	RocksFullSnapshotStrategy.asyncSnapshot(FullSnapshotResources<K> fullRocksDBSnapshotResources, long checkpointId, long timestamp, CheckpointStreamFactory checkpointStreamFactory, CheckpointOptions checkpointOptions)
SnapshotStrategy.SnapshotResultSupplier<KeyedStateHandle>	RocksIncrementalSnapshotStrategy.asyncSnapshot(org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy.IncrementalRocksDBSnapshotResources snapshotResources, long checkpointId, long timestamp, CheckpointStreamFactory checkpointStreamFactory, CheckpointOptions checkpointOptions)

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

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

Modifier and Type	Method and Description
KeyedStateHandle	SubtaskState.getManagedKeyedState() Deprecated.
KeyedStateHandle	SubtaskState.getRawKeyedState() Deprecated.

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

Modifier and Type	Method and Description
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<KeyedStateHandle>	PrioritizedOperatorSubtaskState.getJobManagerRawKeyedState() Returns the raw keyed state from the job manager, which represents the ground truth about what this state should represent.
StateObjectCollection<KeyedStateHandle>	OperatorSubtaskState.getManagedKeyedState()
static List<KeyedStateHandle>	StateAssignmentOperation.getManagedKeyedStateHandles(OperatorState operatorState, KeyGroupRange subtaskKeyGroupRange) Collect managedKeyedStateHandles which have intersection with given KeyGroupRange from operatorState.
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<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.
StateObjectCollection<KeyedStateHandle>	OperatorSubtaskState.getRawKeyedState()
static List<KeyedStateHandle>	StateAssignmentOperation.getRawKeyedStateHandles(OperatorState operatorState, KeyGroupRange subtaskKeyGroupRange) Collect rawKeyedStateHandles which have intersection with given KeyGroupRange from operatorState.

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

Modifier and Type	Method and Description
OperatorSubtaskState.Builder	OperatorSubtaskState.Builder.setManagedKeyedState(KeyedStateHandle managedKeyedState)
OperatorSubtaskState.Builder	OperatorSubtaskState.Builder.setRawKeyedState(KeyedStateHandle rawKeyedState)

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

Modifier and Type	Method and Description
static void	StateAssignmentOperation.extractIntersectingState(Collection<? extends KeyedStateHandle> originalSubtaskStateHandles, KeyGroupRange rangeToExtract, List<KeyedStateHandle> extractedStateCollector) Extracts certain key group ranges from the given state handles and adds them to the collector.
static void	StateAssignmentOperation.extractIntersectingState(Collection<? extends KeyedStateHandle> originalSubtaskStateHandles, KeyGroupRange rangeToExtract, List<KeyedStateHandle> extractedStateCollector) Extracts certain key group ranges from the given state handles and adds them to the collector.
OperatorSubtaskState.Builder	OperatorSubtaskState.Builder.setManagedKeyedState(StateObjectCollection<KeyedStateHandle> managedKeyedState)
OperatorSubtaskState.Builder	OperatorSubtaskState.Builder.setRawKeyedState(StateObjectCollection<KeyedStateHandle> rawKeyedState)

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

Constructor and Description
SubtaskState(ChainedStateHandle<OperatorStateHandle> managedOperatorState, ChainedStateHandle<OperatorStateHandle> rawOperatorState, KeyedStateHandle managedKeyedState, KeyedStateHandle rawKeyedState) Deprecated.

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

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

Modifier and Type	Method and Description
static KeyedStateHandle	MetadataV3Serializer.deserializeKeyedStateHandleUtil(DataInputStream dis)

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

Modifier and Type	Method and Description
static void	MetadataV3Serializer.serializeKeyedStateHandleUtil(KeyedStateHandle stateHandle, DataOutputStream dos)

Uses of KeyedStateHandle in org.apache.flink.runtime.state

Subinterfaces of KeyedStateHandle in org.apache.flink.runtime.state

Modifier and Type	Interface and Description
interface	IncrementalKeyedStateHandle Common interface to all incremental KeyedStateHandle.
interface	SavepointKeyedStateHandle A KeyedStateHandle that points to a savepoint taken in the unified format.

Classes in org.apache.flink.runtime.state that implement KeyedStateHandle

Modifier and Type	Class and Description
class	DirectoryKeyedStateHandle This class is a keyed state handle based on a directory.
class	IncrementalLocalKeyedStateHandle State handle for local copies of IncrementalRemoteKeyedStateHandle.
class	IncrementalRemoteKeyedStateHandle The handle to states of an incremental snapshot.
class	KeyGroupsSavepointStateHandle A KeyGroupsStateHandle that describes a savepoint in the unified format.
class	KeyGroupsStateHandle A handle to the partitioned stream operator state after it has been checkpointed.

Fields in org.apache.flink.runtime.state with type parameters of type KeyedStateHandle

Modifier and Type	Field and Description
protected RunnableFuture<SnapshotResult<KeyedStateHandle>>	StateSnapshotContextSynchronousImpl.keyedStateCheckpointClosingFuture
protected Collection<KeyedStateHandle>	AbstractKeyedStateBackendBuilder.restoreStateHandles

Methods in org.apache.flink.runtime.state that return KeyedStateHandle

Modifier and Type	Method and Description
KeyedStateHandle	CheckpointStreamWithResultProvider.KeyedStateHandleFactory.create(KeyGroupRangeOffsets keyGroupRangeOffsets, StreamStateHandle streamStateHandle)
KeyedStateHandle	IncrementalRemoteKeyedStateHandle.getIntersection(KeyGroupRange keyGroupRange)
KeyedStateHandle	KeyedStateHandle.getIntersection(KeyGroupRange keyGroupRange) Returns a state over a range that is the intersection between this handle's key-group range and the provided key-group range.
KeyedStateHandle	DirectoryKeyedStateHandle.getIntersection(KeyGroupRange otherKeyGroupRange)

Methods in org.apache.flink.runtime.state that return types with arguments of type KeyedStateHandle

Modifier and Type	Method and Description
SnapshotStrategy.SnapshotResultSupplier<KeyedStateHandle>	SavepointSnapshotStrategy.asyncSnapshot(FullSnapshotResources<K> savepointResources, long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions)
SnapshotResult<KeyedStateHandle>	FullSnapshotAsyncWriter.get(CloseableRegistry snapshotCloseableRegistry)
RunnableFuture<SnapshotResult<KeyedStateHandle>>	StateSnapshotContextSynchronousImpl.getKeyedStateStreamFuture()
static SnapshotResult<KeyedStateHandle>	CheckpointStreamWithResultProvider.toKeyedStateHandleSnapshotResult(SnapshotResult<StreamStateHandle> snapshotResult, KeyGroupRangeOffsets keyGroupRangeOffsets, CheckpointStreamWithResultProvider.KeyedStateHandleFactory stateHandleFactory) Helper method that takes a SnapshotResult and a KeyGroupRangeOffsets and creates a SnapshotResult by combining the key groups offsets with all the present stream state handles.

Method parameters in org.apache.flink.runtime.state with type arguments of type KeyedStateHandle

Modifier and Type	Method and Description
abstract <K> AbstractKeyedStateBackend<K>	AbstractStateBackend.createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry)
<K> CheckpointableKeyedStateBackend<K>	StateBackend.createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry) Creates a new CheckpointableKeyedStateBackend that is responsible for holding keyed state and checkpointing it.
default <K> CheckpointableKeyedStateBackend<K>	StateBackend.createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry, double managedMemoryFraction) Creates a new CheckpointableKeyedStateBackend with the given managed memory fraction.
abstract <K> AbstractKeyedStateBackend<K>	AbstractManagedMemoryStateBackend.createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry, double managedMemoryFraction)

Constructor parameters in org.apache.flink.runtime.state with type arguments of type KeyedStateHandle

Constructor and Description

AbstractKeyedStateBackendBuilder(TaskKvStateRegistry kvStateRegistry, TypeSerializer<K> keySerializer, ClassLoader userCodeClassLoader, int numberOfKeyGroups, KeyGroupRange keyGroupRange, ExecutionConfig executionConfig, TtlTimeProvider ttlTimeProvider, LatencyTrackingStateConfig latencyTrackingStateConfig, Collection<KeyedStateHandle> stateHandles, StreamCompressionDecorator keyGroupCompressionDecorator, CloseableRegistry cancelStreamRegistry)

Uses of KeyedStateHandle in org.apache.flink.runtime.state.changelog

Subinterfaces of KeyedStateHandle in org.apache.flink.runtime.state.changelog

Modifier and Type	Interface and Description
interface	ChangelogStateBackendHandle A handle to ChangelogStateBackend state.
interface	ChangelogStateHandle A handle to saved state changes.

Classes in org.apache.flink.runtime.state.changelog that implement KeyedStateHandle

Modifier and Type	Class and Description
static class	ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl
class	ChangelogStateHandleStreamImpl ChangelogStateHandle implementation based on StreamStateHandle.

Methods in org.apache.flink.runtime.state.changelog that return KeyedStateHandle

Modifier and Type	Method and Description
KeyedStateHandle	ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl.getIntersection(KeyGroupRange keyGroupRange)
KeyedStateHandle	ChangelogStateHandleStreamImpl.getIntersection(KeyGroupRange keyGroupRange)

Methods in org.apache.flink.runtime.state.changelog that return types with arguments of type KeyedStateHandle

Modifier and Type	Method and Description
List<KeyedStateHandle>	ChangelogStateBackendHandle.getMaterializedStateHandles()
List<KeyedStateHandle>	ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl.getMaterializedStateHandles()

Method parameters in org.apache.flink.runtime.state.changelog with type arguments of type KeyedStateHandle

Modifier and Type	Method and Description
static ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl	ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl.restore(List<KeyedStateHandle> materialized, List<ChangelogStateHandle> nonMaterialized, KeyGroupRange keyGroupRange, long materializationID, long persistedSizeOfThisCheckpoint, StateHandleID stateHandleId)

Constructor parameters in org.apache.flink.runtime.state.changelog with type arguments of type KeyedStateHandle

Constructor and Description
ChangelogStateBackendHandleImpl(List<KeyedStateHandle> materialized, List<ChangelogStateHandle> nonMaterialized, KeyGroupRange keyGroupRange, long materializationID, long persistedSizeOfThisCheckpoint)

Uses of KeyedStateHandle in org.apache.flink.runtime.state.changelog.inmemory

Classes in org.apache.flink.runtime.state.changelog.inmemory that implement KeyedStateHandle

Modifier and Type	Class and Description
class	InMemoryChangelogStateHandle In-memory ChangelogStateHandle.

Methods in org.apache.flink.runtime.state.changelog.inmemory that return KeyedStateHandle

Modifier and Type	Method and Description
KeyedStateHandle	InMemoryChangelogStateHandle.getIntersection(KeyGroupRange keyGroupRange)

Uses of KeyedStateHandle in org.apache.flink.runtime.state.filesystem

Method parameters in org.apache.flink.runtime.state.filesystem with type arguments of type KeyedStateHandle

Modifier and Type	Method and Description
<K> AbstractKeyedStateBackend<K>	FsStateBackend.createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry) Deprecated.

Uses of KeyedStateHandle in org.apache.flink.runtime.state.hashmap

Method parameters in org.apache.flink.runtime.state.hashmap with type arguments of type KeyedStateHandle

Modifier and Type	Method and Description
<K> AbstractKeyedStateBackend<K>	HashMapStateBackend.createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry)

Uses of KeyedStateHandle in org.apache.flink.runtime.state.heap

Methods in org.apache.flink.runtime.state.heap that return types with arguments of type KeyedStateHandle

Modifier and Type	Method and Description
RunnableFuture<SnapshotResult<KeyedStateHandle>>	HeapKeyedStateBackend.snapshot(long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions)

Constructor parameters in org.apache.flink.runtime.state.heap with type arguments of type KeyedStateHandle

Constructor and Description

HeapKeyedStateBackendBuilder(TaskKvStateRegistry kvStateRegistry, TypeSerializer<K> keySerializer, ClassLoader userCodeClassLoader, int numberOfKeyGroups, KeyGroupRange keyGroupRange, ExecutionConfig executionConfig, TtlTimeProvider ttlTimeProvider, LatencyTrackingStateConfig latencyTrackingStateConfig, Collection<KeyedStateHandle> stateHandles, StreamCompressionDecorator keyGroupCompressionDecorator, LocalRecoveryConfig localRecoveryConfig, HeapPriorityQueueSetFactory priorityQueueSetFactory, boolean asynchronousSnapshots, CloseableRegistry cancelStreamRegistry)

Uses of KeyedStateHandle in org.apache.flink.runtime.state.memory

Method parameters in org.apache.flink.runtime.state.memory with type arguments of type KeyedStateHandle

Modifier and Type	Method and Description
<K> AbstractKeyedStateBackend<K>	MemoryStateBackend.createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry) Deprecated.

Uses of KeyedStateHandle in org.apache.flink.runtime.state.restore

Constructor parameters in org.apache.flink.runtime.state.restore with type arguments of type KeyedStateHandle

Constructor and Description
FullSnapshotRestoreOperation(KeyGroupRange keyGroupRange, ClassLoader userCodeClassLoader, Collection<KeyedStateHandle> restoreStateHandles, StateSerializerProvider<K> keySerializerProvider)

Uses of KeyedStateHandle in org.apache.flink.state.api.input.splits

Constructor parameters in org.apache.flink.state.api.input.splits with type arguments of type KeyedStateHandle

Constructor and Description
KeyGroupRangeInputSplit(List<KeyedStateHandle> managedKeyedState, List<KeyedStateHandle> rawKeyedState, int numKeyGroups, int split)
KeyGroupRangeInputSplit(List<KeyedStateHandle> managedKeyedState, List<KeyedStateHandle> rawKeyedState, int numKeyGroups, int split)

Uses of KeyedStateHandle in org.apache.flink.state.changelog

Methods in org.apache.flink.state.changelog that return types with arguments of type KeyedStateHandle

Modifier and Type	Method and Description
RunnableFuture<SnapshotResult<KeyedStateHandle>>	ChangelogKeyedStateBackend.snapshot(long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions)

Method parameters in org.apache.flink.state.changelog with type arguments of type KeyedStateHandle

Modifier and Type	Method and Description
<K> ChangelogKeyedStateBackend<K>	ChangelogStateBackend.createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry)
<K> CheckpointableKeyedStateBackend<K>	ChangelogStateBackend.createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry, double managedMemoryFraction)
void	ChangelogKeyedStateBackend.updateChangelogSnapshotState(SnapshotResult<KeyedStateHandle> materializedSnapshot, long materializationID, SequenceNumber upTo) This method is not thread safe.

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

Methods in org.apache.flink.streaming.api.operators that return types with arguments of type KeyedStateHandle

Modifier and Type	Method and Description
RunnableFuture<SnapshotResult<KeyedStateHandle>>	OperatorSnapshotFutures.getKeyedStateManagedFuture()
RunnableFuture<SnapshotResult<KeyedStateHandle>>	OperatorSnapshotFutures.getKeyedStateRawFuture()
static SnapshotStrategyRunner<KeyedStateHandle,? extends FullSnapshotResources<?>>	StreamOperatorStateHandler.prepareCanonicalSavepoint(CheckpointableKeyedStateBackend<?> keyedStateBackend, CloseableRegistry closeableRegistry)

Method parameters in org.apache.flink.streaming.api.operators with type arguments of type KeyedStateHandle

Modifier and Type	Method and Description
protected CloseableIterable<KeyGroupStatePartitionStreamProvider>	StreamTaskStateInitializerImpl.rawKeyedStateInputs(Iterator<StateObjectCollection<KeyedStateHandle>> restoreStateAlternatives)
void	OperatorSnapshotFutures.setKeyedStateManagedFuture(RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateManagedFuture)
void	OperatorSnapshotFutures.setKeyedStateRawFuture(RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateRawFuture)

Constructor parameters in org.apache.flink.streaming.api.operators with type arguments of type KeyedStateHandle

Constructor and Description
OperatorSnapshotFutures(RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateManagedFuture, RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateRawFuture, RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateManagedFuture, RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateRawFuture, Future<SnapshotResult<StateObjectCollection<InputChannelStateHandle>>> inputChannelStateFuture, Future<SnapshotResult<StateObjectCollection<ResultSubpartitionStateHandle>>> resultSubpartitionStateFuture)
OperatorSnapshotFutures(RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateManagedFuture, RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateRawFuture, RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateManagedFuture, RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateRawFuture, Future<SnapshotResult<StateObjectCollection<InputChannelStateHandle>>> inputChannelStateFuture, Future<SnapshotResult<StateObjectCollection<ResultSubpartitionStateHandle>>> resultSubpartitionStateFuture)

Uses of KeyedStateHandle in org.apache.flink.streaming.api.operators.sorted.state

Methods in org.apache.flink.streaming.api.operators.sorted.state that return types with arguments of type KeyedStateHandle

Modifier and Type	Method and Description
RunnableFuture<SnapshotResult<KeyedStateHandle>>	BatchExecutionKeyedStateBackend.snapshot(long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions)

Method parameters in org.apache.flink.streaming.api.operators.sorted.state with type arguments of type KeyedStateHandle

Modifier and Type	Method and Description
<K> CheckpointableKeyedStateBackend<K>	BatchExecutionStateBackend.createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry)