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

Class RocksDBFullSnapshotResources<K>

java.lang.Object

org.apache.flink.contrib.streaming.state.snapshot.RocksDBFullSnapshotResources<K>

All Implemented Interfaces:

FullSnapshotResources<K>, SnapshotResources

public class RocksDBFullSnapshotResources<K>
extends Object
implements FullSnapshotResources<K>

A FullSnapshotResources for the RocksDB backend.

Constructor Summary

Constructors

Constructor and Description

RocksDBFullSnapshotResources(ResourceGuard.Lease lease, org.rocksdb.Snapshot snapshot, List<RocksDBKeyedStateBackend.RocksDbKvStateInfo> metaDataCopy, List<HeapPriorityQueueStateSnapshot<?>> heapPriorityQueuesSnapshots, List<StateMetaInfoSnapshot> stateMetaInfoSnapshots, org.rocksdb.RocksDB db, int keyGroupPrefixBytes, KeyGroupRange keyGroupRange, TypeSerializer<K> keySerializer, StreamCompressionDecorator streamCompressionDecorator)

Method Summary

Modifier and Type	Method and Description
static <K> RocksDBFullSnapshotResources<K>	create(LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, Map<String,HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, org.rocksdb.RocksDB db, ResourceGuard rocksDBResourceGuard, KeyGroupRange keyGroupRange, TypeSerializer<K> keySerializer, int keyGroupPrefixBytes, StreamCompressionDecorator keyGroupCompressionDecorator)
KeyValueStateIterator	createKVStateIterator() Returns a KeyValueStateIterator for iterating over all key-value states for this snapshot resources.
KeyGroupRange	getKeyGroupRange() Returns the KeyGroupRange of this snapshot.
TypeSerializer<K>	getKeySerializer() Returns key TypeSerializer.
List<StateMetaInfoSnapshot>	getMetaInfoSnapshots() Returns the list of meta info snapshots for this state snapshot.
StreamCompressionDecorator	getStreamCompressionDecorator() Returns the StreamCompressionDecorator that should be used for writing.
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

Constructor Detail

RocksDBFullSnapshotResources

public RocksDBFullSnapshotResources(ResourceGuard.Lease lease,
                                    org.rocksdb.Snapshot snapshot,
                                    List<RocksDBKeyedStateBackend.RocksDbKvStateInfo> metaDataCopy,
                                    List<HeapPriorityQueueStateSnapshot<?>> heapPriorityQueuesSnapshots,
                                    List<StateMetaInfoSnapshot> stateMetaInfoSnapshots,
                                    org.rocksdb.RocksDB db,
                                    int keyGroupPrefixBytes,
                                    KeyGroupRange keyGroupRange,
                                    TypeSerializer<K> keySerializer,
                                    StreamCompressionDecorator streamCompressionDecorator)

Method Detail

create

public static <K> RocksDBFullSnapshotResources<K> create(LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
                                                         Map<String,HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates,
                                                         org.rocksdb.RocksDB db,
                                                         ResourceGuard rocksDBResourceGuard,
                                                         KeyGroupRange keyGroupRange,
                                                         TypeSerializer<K> keySerializer,
                                                         int keyGroupPrefixBytes,
                                                         StreamCompressionDecorator keyGroupCompressionDecorator)
                                                  throws IOException

Throws:

IOException

createKVStateIterator

public KeyValueStateIterator createKVStateIterator()
                                            throws IOException

Description copied from interface: FullSnapshotResources

Returns a KeyValueStateIterator for iterating over all key-value states for this snapshot resources.

Specified by:

createKVStateIterator in interface FullSnapshotResources<K>

Throws:

IOException

getMetaInfoSnapshots

public List<StateMetaInfoSnapshot> getMetaInfoSnapshots()

Description copied from interface: FullSnapshotResources

Returns the list of meta info snapshots for this state snapshot.

Specified by:

getMetaInfoSnapshots in interface FullSnapshotResources<K>

getKeyGroupRange

public KeyGroupRange getKeyGroupRange()

Description copied from interface: FullSnapshotResources

Returns the KeyGroupRange of this snapshot.

Specified by:

getKeyGroupRange in interface FullSnapshotResources<K>

getKeySerializer

public TypeSerializer<K> getKeySerializer()

Description copied from interface: FullSnapshotResources

Returns key TypeSerializer.

Specified by:

getKeySerializer in interface FullSnapshotResources<K>

getStreamCompressionDecorator

public StreamCompressionDecorator getStreamCompressionDecorator()

Description copied from interface: FullSnapshotResources

Returns the StreamCompressionDecorator that should be used for writing.

Specified by:

getStreamCompressionDecorator in interface FullSnapshotResources<K>

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