org.apache.flink.contrib.streaming.state.snapshot

类 RocksDBSnapshotStrategyBase.PreviousSnapshot

java.lang.Object

org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase.PreviousSnapshot

封闭类:

RocksDBSnapshotStrategyBase<K,R extends org.apache.flink.runtime.state.SnapshotResources>

protected static class RocksDBSnapshotStrategyBase.PreviousSnapshot
extends Object

Previous snapshot with uploaded sst files.

构造器概要

构造器

限定符	构造器和说明
protected	PreviousSnapshot(Map<org.apache.flink.runtime.state.StateHandleID,Long> confirmedSstFiles)

方法概要

限定符和类型	方法和说明
protected Optional<org.apache.flink.runtime.state.StreamStateHandle>	getUploaded(org.apache.flink.runtime.state.StateHandleID stateHandleID)

从类继承的方法 java.lang.Object

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

构造器详细资料

PreviousSnapshot

protected PreviousSnapshot(@Nullable
                           Map<org.apache.flink.runtime.state.StateHandleID,Long> confirmedSstFiles)

方法详细资料

getUploaded

protected Optional<org.apache.flink.runtime.state.StreamStateHandle> getUploaded(org.apache.flink.runtime.state.StateHandleID stateHandleID)