Package | Description |
---|---|
org.apache.flink.contrib.streaming.state.snapshot |
Modifier and Type | Field and Description |
---|---|
protected static RocksDBSnapshotStrategyBase.PreviousSnapshot |
RocksDBSnapshotStrategyBase.EMPTY_PREVIOUS_SNAPSHOT |
protected RocksDBSnapshotStrategyBase.PreviousSnapshot |
RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources.previousSnapshot |
Modifier and Type | Method and Description |
---|---|
protected abstract RocksDBSnapshotStrategyBase.PreviousSnapshot |
RocksDBSnapshotStrategyBase.snapshotMetaData(long checkpointId,
List<StateMetaInfoSnapshot> stateMetaInfoSnapshots) |
protected RocksDBSnapshotStrategyBase.PreviousSnapshot |
RocksIncrementalSnapshotStrategy.snapshotMetaData(long checkpointId,
List<StateMetaInfoSnapshot> stateMetaInfoSnapshots) |
protected RocksDBSnapshotStrategyBase.PreviousSnapshot |
RocksNativeFullSnapshotStrategy.snapshotMetaData(long checkpointId,
List<StateMetaInfoSnapshot> stateMetaInfoSnapshots) |
Constructor and Description |
---|
NativeRocksDBSnapshotResources(SnapshotDirectory snapshotDirectory,
RocksDBSnapshotStrategyBase.PreviousSnapshot previousSnapshot,
List<StateMetaInfoSnapshot> stateMetaInfoSnapshots) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.