K
- type of key.N
- type of namespace.S
- type of state.@Internal public class NestedMapsStateTable<K,N,S> extends StateTable<K,N,S>
StateTable
uses NestedStateMap
.keyContext, keyGroupedStateMaps, keyGroupRange, keySerializer, metaInfo
Constructor and Description |
---|
NestedMapsStateTable(InternalKeyContext<K> keyContext,
RegisteredKeyValueStateBackendMetaInfo<N,S> metaInfo,
TypeSerializer<K> keySerializer)
Creates a new
NestedMapsStateTable for the given key context and meta info. |
Modifier and Type | Method and Description |
---|---|
protected NestedStateMap<K,N,S> |
createStateMap() |
org.apache.flink.runtime.state.heap.NestedMapsStateTable.NestedMapsStateTableSnapshot<K,N,S> |
stateSnapshot()
Returns a snapshot of the state.
|
containsKey, get, get, getKeyGroupOffset, getKeys, getKeysAndNamespaces, getKeySerializer, getMapForKeyGroup, getMetaInfo, getNamespaceSerializer, getState, getStateIncrementalVisitor, getStateSerializer, isEmpty, iterator, keyGroupReader, put, put, remove, removeAndGetOld, setMetaInfo, size, sizeOfNamespace, transform
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public NestedMapsStateTable(InternalKeyContext<K> keyContext, RegisteredKeyValueStateBackendMetaInfo<N,S> metaInfo, TypeSerializer<K> keySerializer)
NestedMapsStateTable
for the given key context and meta info.keyContext
- the key context.metaInfo
- the meta information for this state table.keySerializer
- the serializer of the key.protected NestedStateMap<K,N,S> createStateMap()
createStateMap
in class StateTable<K,N,S>
@Nonnull public org.apache.flink.runtime.state.heap.NestedMapsStateTable.NestedMapsStateTableSnapshot<K,N,S> stateSnapshot()
StateSnapshotRestore
stateSnapshot
in interface StateSnapshotRestore
stateSnapshot
in class StateTable<K,N,S>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.