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.
|
Modifier and Type | Method and Description |
---|---|
RocksDBKeyedStateBackend<K> |
RocksDBKeyedStateBackendBuilder.build() |
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.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.