Package org.apache.flink.runtime.state
Interface TestableKeyedStateBackend<K>
-
- All Superinterfaces:
Disposable
,KeyedStateBackend<K>
,KeyedStateFactory
,PriorityQueueSetFactory
- All Known Implementing Classes:
AbstractKeyedStateBackend
,ChangelogKeyedStateBackend
,ForStSyncKeyedStateBackend
,HeapKeyedStateBackend
,RocksDBKeyedStateBackend
@VisibleForTesting public interface TestableKeyedStateBackend<K> extends KeyedStateBackend<K>
A keyed state backend interface for internal testing purpose.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.flink.runtime.state.KeyedStateBackend
KeyedStateBackend.KeySelectionListener<K>
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default KeyedStateBackend<K>
getDelegatedKeyedStateBackend(boolean recursive)
int
numKeyValueStateEntries()
Returns the total number of state entries across all keys/namespaces.-
Methods inherited from interface org.apache.flink.runtime.state.KeyedStateBackend
applyToAllKeys, deregisterKeySelectionListener, dispose, getCurrentKey, getKeys, getKeysAndNamespaces, getKeySerializer, getOrCreateKeyedState, getPartitionedState, isSafeToReuseKVState, registerKeySelectionListener, setCurrentKey, setCurrentKeyAndKeyGroup
-
Methods inherited from interface org.apache.flink.runtime.state.KeyedStateFactory
createOrUpdateInternalState, createOrUpdateInternalState, createOrUpdateInternalState
-
Methods inherited from interface org.apache.flink.runtime.state.PriorityQueueSetFactory
create, create
-
-
-
-
Method Detail
-
numKeyValueStateEntries
int numKeyValueStateEntries()
Returns the total number of state entries across all keys/namespaces.
-
getDelegatedKeyedStateBackend
default KeyedStateBackend<K> getDelegatedKeyedStateBackend(boolean recursive)
- Parameters:
recursive
- true if the call should be recursive- Returns:
- delegated
KeyedStateBackend
if this backends delegates its responisibilities..
-
-