K
- Type of the key by which state is keyed.public interface CheckpointableKeyedStateBackend<K> extends KeyedStateBackend<K>, SnapshotStrategy<SnapshotResult<KeyedStateHandle>>, Closeable
KeyedStateBackend
interface, which encapsulates methods
responsible for keyed state management and the SnapshotStrategy
which tells the system
how to snapshot the underlying state.
NOTE: State backends that need to be notified of completed checkpoints can additionally
implement the CheckpointListener
interface.
KeyedStateBackend.KeySelectionListener<K>
Modifier and Type | Method and Description |
---|---|
KeyGroupRange |
getKeyGroupRange()
Returns the key groups which this state backend is responsible for.
|
applyToAllKeys, deregisterKeySelectionListener, dispose, getCurrentKey, getKeys, getKeysAndNamespaces, getKeySerializer, getOrCreateKeyedState, getPartitionedState, registerKeySelectionListener, setCurrentKey
createInternalState, createInternalState
create
snapshot
KeyGroupRange getKeyGroupRange()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.