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(Collection<org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath> confirmedSstFiles)

方法概要

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

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

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

构造器详细资料

PreviousSnapshot

protected PreviousSnapshot(@Nullable
                           Collection<org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath> confirmedSstFiles)

方法详细资料

getUploaded

protected Optional<org.apache.flink.runtime.state.StreamStateHandle> getUploaded(String filename)