Package | Description |
---|---|
org.apache.flink.contrib.streaming.state |
Modifier and Type | Field and Description |
---|---|
protected RocksDBKeyedStateBackend<K> |
AbstractRocksDBState.backend
Backend that holds the actual RocksDB instance where we store state.
|
Constructor and Description |
---|
AbstractRocksDBState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<V> valueSerializer,
V defaultValue,
RocksDBKeyedStateBackend<K> backend)
Creates a new RocksDB backed state.
|
RocksDBAggregatingState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<ACC> valueSerializer,
ACC defaultValue,
AggregateFunction<T,ACC,R> aggFunction,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBAggregatingState . |
RocksDBFoldingState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<ACC> valueSerializer,
ACC defaultValue,
FoldFunction<T,ACC> foldFunction,
RocksDBKeyedStateBackend<K> backend)
Deprecated.
Creates a new
RocksDBFoldingState . |
RocksDBListState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<List<V>> valueSerializer,
List<V> defaultValue,
TypeSerializer<V> elementSerializer,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBListState . |
RocksDBMapState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<Map<UK,UV>> valueSerializer,
Map<UK,UV> defaultValue,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBMapState . |
RocksDBReducingState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<V> valueSerializer,
V defaultValue,
ReduceFunction<V> reduceFunction,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBReducingState . |
RocksDBValueState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<V> valueSerializer,
V defaultValue,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBValueState . |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.