Package | Description |
---|---|
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 | 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.
|
Constructor and Description |
---|
AbstractHeapMergingState(StateTable<K,N,SV> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<SV> valueSerializer,
TypeSerializer<N> namespaceSerializer,
SV defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
AbstractHeapState(StateTable<K,N,SV> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<SV> valueSerializer,
TypeSerializer<N> namespaceSerializer,
SV defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapAggregatingState(StateTable<K,N,ACC> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<ACC> valueSerializer,
TypeSerializer<N> namespaceSerializer,
ACC defaultValue,
AggregateFunction<IN,ACC,OUT> aggregateFunction)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapFoldingState(StateTable<K,N,ACC> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<ACC> valueSerializer,
TypeSerializer<N> namespaceSerializer,
ACC defaultValue,
FoldFunction<T,ACC> foldFunction)
Deprecated.
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapListState(StateTable<K,N,List<V>> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<List<V>> valueSerializer,
TypeSerializer<N> namespaceSerializer,
List<V> defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapMapState(StateTable<K,N,Map<UK,UV>> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<Map<UK,UV>> valueSerializer,
TypeSerializer<N> namespaceSerializer,
Map<UK,UV> defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapReducingState(StateTable<K,N,V> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer,
TypeSerializer<N> namespaceSerializer,
V defaultValue,
ReduceFunction<V> reduceFunction)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapValueState(StateTable<K,N,V> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer,
TypeSerializer<N> namespaceSerializer,
V defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.