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

Class RocksDBSnapshotStrategyBase.PreviousSnapshot

java.lang.Object

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

Enclosing class:

RocksDBSnapshotStrategyBase<K,R extends SnapshotResources>

protected static class RocksDBSnapshotStrategyBase.PreviousSnapshot
extends Object

Previous snapshot with uploaded sst files.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PreviousSnapshot(Map<StateHandleID,Long> confirmedSstFiles)

Method Summary

Modifier and Type	Method and Description
protected Optional<StreamStateHandle>	getUploaded(StateHandleID stateHandleID)

Methods inherited from class java.lang.Object

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

Constructor Detail

PreviousSnapshot

protected PreviousSnapshot(@Nullable
                           Map<StateHandleID,Long> confirmedSstFiles)

Method Detail

getUploaded

protected Optional<StreamStateHandle> getUploaded(StateHandleID stateHandleID)