Package | Description |
---|---|
org.apache.flink.runtime.state.heap |
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 |
---|
AbstractHeapState(KeyedStateBackend<K> backend,
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.
|
HeapFoldingState(KeyedStateBackend<K> backend,
FoldingStateDescriptor<T,ACC> 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.
|
HeapListState(KeyedStateBackend<K> backend,
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.
|
HeapReducingState(KeyedStateBackend<K> backend,
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(KeyedStateBackend<K> backend,
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–2017 The Apache Software Foundation. All rights reserved.