Package org.apache.flink.state.forst.restore

Class ForStRestoreResult

java.lang.Object

org.apache.flink.state.forst.restore.ForStRestoreResult

public class ForStRestoreResult
extends Object

Entity holding result of ForSt instance restore.

Constructor Summary

Constructors

Constructor	Description
ForStRestoreResult(org.forstdb.RocksDB db, org.forstdb.ColumnFamilyHandle defaultColumnFamilyHandle, ForStNativeMetricMonitor 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.forstdb.RocksDB	getDb()
org.forstdb.ColumnFamilyHandle	getDefaultColumnFamilyHandle()
long	getLastCompletedCheckpointId()
ForStNativeMetricMonitor	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

ForStRestoreResult

public ForStRestoreResult(org.forstdb.RocksDB db,
                          org.forstdb.ColumnFamilyHandle defaultColumnFamilyHandle,
                          @Nullable
                          ForStNativeMetricMonitor nativeMetricMonitor,
                          long lastCompletedCheckpointId,
                          UUID backendUID,
                          SortedMap<Long,Collection<org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath>> restoredSstFiles)

Method Detail

getDb

public org.forstdb.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.forstdb.ColumnFamilyHandle getDefaultColumnFamilyHandle()

getNativeMetricMonitor

@Nullable
public ForStNativeMetricMonitor getNativeMetricMonitor()