Package org.apache.flink.state.rocksdb.snapshot

Class RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation

java.lang.Object

org.apache.flink.state.rocksdb.snapshot.RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation

All Implemented Interfaces:

SnapshotStrategy.SnapshotResultSupplier<KeyedStateHandle>

Enclosing class:

RocksDBSnapshotStrategyBase<K,R extends SnapshotResources>

protected abstract class RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation
extends Object
implements SnapshotStrategy.SnapshotResultSupplier<KeyedStateHandle>

Common operation in native rocksdb snapshot result supplier.

Field Summary

Fields

Modifier and Type	Field	Description
protected long	checkpointId	Id for the current checkpoint.
protected CheckpointStreamFactory	checkpointStreamFactory	Stream factory that creates the output streams to DFS.
protected SnapshotDirectory	localBackupDirectory	Local directory for the RocksDB native backup.
protected List<StateMetaInfoSnapshot>	stateMetaInfoSnapshots	The state meta data.
protected CloseableRegistry	tmpResourcesRegistry

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RocksDBSnapshotOperation(long checkpointId, CheckpointStreamFactory checkpointStreamFactory, SnapshotDirectory localBackupDirectory, List<StateMetaInfoSnapshot> stateMetaInfoSnapshots)

Method Summary

Modifier and Type	Method	Description
protected Optional<KeyedStateHandle>	getLocalSnapshot(StreamStateHandle localStreamStateHandle, List<IncrementalKeyedStateHandle.HandleAndLocalPath> sharedState)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.runtime.state.SnapshotStrategy.SnapshotResultSupplier

get

Field Detail

checkpointId

protected final long checkpointId

Id for the current checkpoint.

checkpointStreamFactory

@Nonnull
protected final CheckpointStreamFactory checkpointStreamFactory

Stream factory that creates the output streams to DFS.

stateMetaInfoSnapshots

@Nonnull
protected final List<StateMetaInfoSnapshot> stateMetaInfoSnapshots

The state meta data.

localBackupDirectory

@Nonnull
protected final SnapshotDirectory localBackupDirectory

Local directory for the RocksDB native backup.

tmpResourcesRegistry

@Nonnull
protected final CloseableRegistry tmpResourcesRegistry

Constructor Detail

RocksDBSnapshotOperation

protected RocksDBSnapshotOperation(long checkpointId,
                                   @Nonnull
                                   CheckpointStreamFactory checkpointStreamFactory,
                                   @Nonnull
                                   SnapshotDirectory localBackupDirectory,
                                   @Nonnull
                                   List<StateMetaInfoSnapshot> stateMetaInfoSnapshots)

Method Detail

getLocalSnapshot

protected Optional<KeyedStateHandle> getLocalSnapshot(@Nullable
                                                      StreamStateHandle localStreamStateHandle,
                                                      List<IncrementalKeyedStateHandle.HandleAndLocalPath> sharedState)
                                               throws IOException

Throws:

IOException