Modifier and Type | Class and Description |
---|---|
class |
RocksDBKeyedStateBackend<K>
A
AbstractKeyedStateBackend that stores its state in RocksDB and will serialize state to
streams provided by a CheckpointStreamFactory upon
checkpointing. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractKeyedStateBackend<K>
Base implementation of KeyedStateBackend.
|
Constructor and Description |
---|
DefaultKeyedStateStore(KeyedStateBackend<?> keyedStateBackend,
ExecutionConfig executionConfig) |
Modifier and Type | Class and Description |
---|---|
class |
HeapKeyedStateBackend<K>
A
AbstractKeyedStateBackend that keeps state on the Java Heap and will serialize state to
streams provided by a CheckpointStreamFactory upon
checkpointing. |
Modifier and Type | Field and Description |
---|---|
protected KeyedStateBackend<K> |
AbstractHeapState.backend |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncHeapKeyedStateBackend<K>
A
AbstractKeyedStateBackend that keeps state on the Java Heap and will serialize state to
streams provided by a CheckpointStreamFactory upon
checkpointing. |
Modifier and Type | Method and Description |
---|---|
<K> KeyedStateBackend<K> |
AbstractStreamOperator.getKeyedStateBackend() |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.