Class ForStSnapshotStrategyBase.PreviousSnapshot
- java.lang.Object
-
- org.apache.flink.state.forst.snapshot.ForStSnapshotStrategyBase.PreviousSnapshot
-
- Enclosing class:
- ForStSnapshotStrategyBase<K,R extends SnapshotResources>
protected static class ForStSnapshotStrategyBase.PreviousSnapshot extends Object
Previous snapshot with uploaded sst files.
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
PreviousSnapshot(Collection<IncrementalKeyedStateHandle.HandleAndLocalPath> confirmedSstFiles)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Optional<StreamStateHandle>
getUploaded(String filename)
-
-
-
Constructor Detail
-
PreviousSnapshot
protected PreviousSnapshot(@Nullable Collection<IncrementalKeyedStateHandle.HandleAndLocalPath> confirmedSstFiles)
-
-
Method Detail
-
getUploaded
protected Optional<StreamStateHandle> getUploaded(String filename)
-
-