org.apache.flink.runtime.state

Interface TestableKeyedStateBackend<K>

All Superinterfaces:

Disposable, KeyedStateBackend<K>, KeyedStateFactory, PriorityQueueSetFactory

All Known Implementing Classes:

AbstractKeyedStateBackend, ChangelogKeyedStateBackend, 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

Modifier and Type	Method and 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, isStateImmutableInStateBackend, registerKeySelectionListener, setCurrentKey

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..