Package | Description |
---|---|
org.apache.flink.contrib.streaming.state |
Modifier and Type | Method and Description |
---|---|
protected abstract KvState<K,N,S,SD,RocksDBStateBackend> |
AbstractRocksDBState.AbstractRocksDBSnapshot.createRocksDBState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
SD stateDesc,
File basePath,
String backupPath,
String restorePath,
org.rocksdb.Options options)
Subclasses must implement this for creating a concrete RocksDB state.
|
KvState<K,N,S,SD,RocksDBStateBackend> |
AbstractRocksDBState.AbstractRocksDBSnapshot.restoreState(RocksDBStateBackend stateBackend,
TypeSerializer<K> keySerializer,
ClassLoader classLoader,
long recoveryTimestamp) |
KvStateSnapshot<K,N,S,SD,RocksDBStateBackend> |
AbstractRocksDBState.snapshot(long checkpointId,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
KvState<K,N,S,SD,RocksDBStateBackend> |
AbstractRocksDBState.AbstractRocksDBSnapshot.restoreState(RocksDBStateBackend stateBackend,
TypeSerializer<K> keySerializer,
ClassLoader classLoader,
long recoveryTimestamp) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.