org.apache.flink.runtime.state

Interface FullSnapshotResources<K>

Type Parameters:

K - type of the backend keys.

All Superinterfaces:

SnapshotResources

All Known Implementing Classes:

RocksDBFullSnapshotResources

@Internal
public interface FullSnapshotResources<K>
extends SnapshotResources

A SnapshotResources to be used with the backend-independent FullSnapshotAsyncWriter.

Method Summary

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

Methods inherited from interface org.apache.flink.runtime.state.SnapshotResources

release

Method Detail

getMetaInfoSnapshots

List<StateMetaInfoSnapshot> getMetaInfoSnapshots()

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

createKVStateIterator

KeyValueStateIterator createKVStateIterator()
                                     throws IOException

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

Throws:

IOException

getKeyGroupRange

KeyGroupRange getKeyGroupRange()

Returns the KeyGroupRange of this snapshot.

getKeySerializer

TypeSerializer<K> getKeySerializer()

Returns key TypeSerializer.

getStreamCompressionDecorator

StreamCompressionDecorator getStreamCompressionDecorator()

Returns the StreamCompressionDecorator that should be used for writing.