Package | Description |
---|---|
org.apache.flink.migration.runtime.state.filesystem | |
org.apache.flink.migration.runtime.state.memory | |
org.apache.flink.runtime.state.heap |
This package contains the classes for key/value state backends that store the state
on the JVM heap as objects.
|
Modifier and Type | Method and Description |
---|---|
StateTable<K,N,SV> |
AbstractFsStateSnapshot.deserialize(String stateName,
HeapKeyedStateBackend<K> stateBackend)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
StateTable<K,N,S> |
MigrationRestoreSnapshot.deserialize(String stateName,
HeapKeyedStateBackend<K> stateBackend)
Deprecated.
|
StateTable<K,N,S> |
AbstractMigrationRestoreStrategy.deserialize(String stateName,
HeapKeyedStateBackend<K> stateBackend)
Deprecated.
|
StateTable<K,N,SV> |
AbstractMemStateSnapshot.deserialize(String stateName,
HeapKeyedStateBackend<K> stateBackend)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
CopyOnWriteStateTable<K,N,S>
Implementation of Flink's in-memory state tables with copy-on-write support.
|
class |
NestedMapsStateTable<K,N,S>
This implementation of
StateTable uses nested HashMap objects. |
Modifier and Type | Field and Description |
---|---|
protected StateTable<K,N,SV> |
AbstractHeapState.stateTable
Map containing the actual key/value pairs
|
Modifier and Type | Method and Description |
---|---|
StateTable<K,N,SV> |
AbstractHeapState.getStateTable()
This should only be used for testing.
|
<N,V> StateTable<K,N,V> |
HeapKeyedStateBackend.newStateTable(RegisteredKeyedBackendStateMetaInfo<N,V> newMetaInfo) |
Constructor and Description |
---|
AbstractHeapMergingState(SD stateDesc,
StateTable<K,N,SV> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer)
Creates a new key/value state for the given hash map of key/value pairs.
|
AbstractHeapState(SD stateDesc,
StateTable<K,N,SV> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapAggregatingState(AggregatingStateDescriptor<IN,ACC,OUT> stateDesc,
StateTable<K,N,ACC> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapFoldingState(FoldingStateDescriptor<T,ACC> stateDesc,
StateTable<K,N,ACC> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer)
Deprecated.
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapListState(ListStateDescriptor<V> stateDesc,
StateTable<K,N,ArrayList<V>> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapMapState(MapStateDescriptor<UK,UV> stateDesc,
StateTable<K,N,HashMap<UK,UV>> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapReducingState(ReducingStateDescriptor<V> stateDesc,
StateTable<K,N,V> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapValueState(ValueStateDescriptor<V> stateDesc,
StateTable<K,N,V> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer)
Creates a new key/value state for the given hash map of key/value pairs.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.