K- Type of the key by which state is keyed.
public interface CheckpointableKeyedStateBackend<K> extends KeyedStateBackend<K>, Snapshotable<SnapshotResult<KeyedStateHandle>>, Closeable
KeyedStateBackendinterface, which encapsulates methods responsible for keyed state management and the
Snapshotablewhich tells the system how to snapshot the underlying state.
NOTE: State backends that need to be notified of completed checkpoints can additionally
|Modifier and Type||Method and Description|
Returns the key groups which this state backend is responsible for.
applyToAllKeys, deregisterKeySelectionListener, dispose, getCurrentKey, getKeys, getKeysAndNamespaces, getKeySerializer, getOrCreateKeyedState, getPartitionedState, isSafeToReuseKVState, isStateImmutableInStateBackend, registerKeySelectionListener, setCurrentKey
createOrUpdateInternalState, createOrUpdateInternalState, createOrUpdateInternalState
@Nonnull SavepointResources<K> savepoint() throws Exception
SavepointResourcesthat can be used by
SavepointSnapshotStrategyto write out a savepoint in the common/unified format.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.