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

Class RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources

java.lang.Object

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

All Implemented Interfaces:

SnapshotResources

Enclosing class:

RocksDBSnapshotStrategyBase<K,R extends SnapshotResources>

protected static class RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources
extends Object
implements SnapshotResources

A SnapshotResources for native rocksdb snapshot.

Field Summary

Fields

Modifier and Type	Field and Description
protected RocksDBSnapshotStrategyBase.PreviousSnapshot	previousSnapshot
protected SnapshotDirectory	snapshotDirectory
protected List<StateMetaInfoSnapshot>	stateMetaInfoSnapshots

Constructor Summary

Constructors

Constructor and Description
NativeRocksDBSnapshotResources(SnapshotDirectory snapshotDirectory, RocksDBSnapshotStrategyBase.PreviousSnapshot previousSnapshot, List<StateMetaInfoSnapshot> stateMetaInfoSnapshots)

Method Summary

Modifier and Type	Method and Description
void	release() Cleans up the resources after the asynchronous part is done.

Methods inherited from class java.lang.Object

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

Field Detail

snapshotDirectory

@Nonnull
protected final SnapshotDirectory snapshotDirectory

previousSnapshot

@Nonnull
protected final RocksDBSnapshotStrategyBase.PreviousSnapshot previousSnapshot

stateMetaInfoSnapshots

@Nonnull
protected final List<StateMetaInfoSnapshot> stateMetaInfoSnapshots

Constructor Detail

NativeRocksDBSnapshotResources

public NativeRocksDBSnapshotResources(SnapshotDirectory snapshotDirectory,
                                      RocksDBSnapshotStrategyBase.PreviousSnapshot previousSnapshot,
                                      List<StateMetaInfoSnapshot> stateMetaInfoSnapshots)

Method Detail

release

public void release()

Description copied from interface: SnapshotResources

Cleans up the resources after the asynchronous part is done.

Specified by:

release in interface SnapshotResources