Package org.apache.flink.contrib.streaming.state.restore

Class RocksDBRestoreResult

java.lang.Object

org.apache.flink.contrib.streaming.state.restore.RocksDBRestoreResult

public class RocksDBRestoreResult
extends Object

Entity holding result of RocksDB instance restore.

Constructor Summary

Constructors

Constructor	Description
RocksDBRestoreResult(org.rocksdb.RocksDB db, org.rocksdb.ColumnFamilyHandle defaultColumnFamilyHandle, RocksDBNativeMetricMonitor nativeMetricMonitor, long lastCompletedCheckpointId, UUID backendUID, SortedMap<Long,Collection<org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath>> restoredSstFiles)

Method Summary

Modifier and Type	Method	Description
UUID	getBackendUID()
org.rocksdb.RocksDB	getDb()
org.rocksdb.ColumnFamilyHandle	getDefaultColumnFamilyHandle()
long	getLastCompletedCheckpointId()
RocksDBNativeMetricMonitor	getNativeMetricMonitor()
SortedMap<Long,Collection<org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath>>	getRestoredSstFiles()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RocksDBRestoreResult

public RocksDBRestoreResult(org.rocksdb.RocksDB db,
                            org.rocksdb.ColumnFamilyHandle defaultColumnFamilyHandle,
                            RocksDBNativeMetricMonitor nativeMetricMonitor,
                            long lastCompletedCheckpointId,
                            UUID backendUID,
                            SortedMap<Long,Collection<org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath>> restoredSstFiles)

Method Detail

getDb

public org.rocksdb.RocksDB getDb()

getLastCompletedCheckpointId

public long getLastCompletedCheckpointId()

getBackendUID

public UUID getBackendUID()

getRestoredSstFiles

public SortedMap<Long,Collection<org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath>> getRestoredSstFiles()

getDefaultColumnFamilyHandle

public org.rocksdb.ColumnFamilyHandle getDefaultColumnFamilyHandle()

getNativeMetricMonitor

public RocksDBNativeMetricMonitor getNativeMetricMonitor()