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

Class RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation

java.lang.Object

org.apache.flink.contrib.streaming.state.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 and 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 and Description
protected	RocksDBSnapshotOperation(long checkpointId, CheckpointStreamFactory checkpointStreamFactory, SnapshotDirectory localBackupDirectory, List<StateMetaInfoSnapshot> stateMetaInfoSnapshots)

Method Summary

Modifier and Type	Method and 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