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 and Description
RocksDBRestoreResult(org.rocksdb.RocksDB db, org.rocksdb.ColumnFamilyHandle defaultColumnFamilyHandle, RocksDBNativeMetricMonitor nativeMetricMonitor, long lastCompletedCheckpointId, UUID backendUID, SortedMap<Long,Collection<IncrementalKeyedStateHandle.HandleAndLocalPath>> restoredSstFiles, CompletableFuture<Void> asyncCompactAfterRestoreFuture)

Method Summary

Modifier and Type	Method and Description
Optional<CompletableFuture<Void>>	getAsyncCompactAfterRestoreFuture()
UUID	getBackendUID()
org.rocksdb.RocksDB	getDb()
org.rocksdb.ColumnFamilyHandle	getDefaultColumnFamilyHandle()
long	getLastCompletedCheckpointId()
RocksDBNativeMetricMonitor	getNativeMetricMonitor()
SortedMap<Long,Collection<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<IncrementalKeyedStateHandle.HandleAndLocalPath>> restoredSstFiles,
                            @Nullable
                            CompletableFuture<Void> asyncCompactAfterRestoreFuture)

Method Detail

getDb

public org.rocksdb.RocksDB getDb()

getLastCompletedCheckpointId

public long getLastCompletedCheckpointId()

getBackendUID

public UUID getBackendUID()

getRestoredSstFiles

public SortedMap<Long,Collection<IncrementalKeyedStateHandle.HandleAndLocalPath>> getRestoredSstFiles()

getDefaultColumnFamilyHandle

public org.rocksdb.ColumnFamilyHandle getDefaultColumnFamilyHandle()

getNativeMetricMonitor

public RocksDBNativeMetricMonitor getNativeMetricMonitor()

getAsyncCompactAfterRestoreFuture

public Optional<CompletableFuture<Void>> getAsyncCompactAfterRestoreFuture()