Uses of Class
org.apache.flink.runtime.state.SnapshotDirectory

Packages that use SnapshotDirectory

Package	Description
org.apache.flink.contrib.streaming.state.snapshot
org.apache.flink.runtime.state

Uses of SnapshotDirectory in org.apache.flink.contrib.streaming.state.snapshot

Fields in org.apache.flink.contrib.streaming.state.snapshot declared as SnapshotDirectory

Modifier and Type	Field and Description
protected SnapshotDirectory	RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation.localBackupDirectory Local directory for the RocksDB native backup.
protected SnapshotDirectory	RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources.snapshotDirectory

Methods in org.apache.flink.contrib.streaming.state.snapshot that return SnapshotDirectory

Modifier and Type	Method and Description
protected SnapshotDirectory	RocksDBSnapshotStrategyBase.prepareLocalSnapshotDirectory(long checkpointId)

Methods in org.apache.flink.contrib.streaming.state.snapshot with parameters of type SnapshotDirectory

Modifier and Type	Method and Description
protected void	RocksDBSnapshotStrategyBase.cleanupIncompleteSnapshot(CloseableRegistry tmpResourcesRegistry, SnapshotDirectory localBackupDirectory)

Constructors in org.apache.flink.contrib.streaming.state.snapshot with parameters of type SnapshotDirectory

Constructor and Description
NativeRocksDBSnapshotResources(SnapshotDirectory snapshotDirectory, RocksDBSnapshotStrategyBase.PreviousSnapshot previousSnapshot, List<StateMetaInfoSnapshot> stateMetaInfoSnapshots)
RocksDBSnapshotOperation(long checkpointId, CheckpointStreamFactory checkpointStreamFactory, SnapshotDirectory localBackupDirectory, List<StateMetaInfoSnapshot> stateMetaInfoSnapshots)

Uses of SnapshotDirectory in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state that return SnapshotDirectory

Modifier and Type	Method and Description
static SnapshotDirectory	SnapshotDirectory.permanent(Path directory) Creates a permanent snapshot directory for the given path, which will not delete the underlying directory in cleanup() after completeSnapshotAndGetHandle() was called.
static SnapshotDirectory	SnapshotDirectory.temporary(File directory) Creates a local temporary snapshot directory for the given path.