Package 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
ASnapshotResources
to be used with the backend-independentFullSnapshotAsyncWriter
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description KeyValueStateIterator
createKVStateIterator()
Returns aKeyValueStateIterator
for iterating over all key-value states for this snapshot resources.KeyGroupRange
getKeyGroupRange()
Returns theKeyGroupRange
of this snapshot.TypeSerializer<K>
getKeySerializer()
Returns keyTypeSerializer
.List<StateMetaInfoSnapshot>
getMetaInfoSnapshots()
Returns the list ofmeta info snapshots
for this state snapshot.StreamCompressionDecorator
getStreamCompressionDecorator()
Returns theStreamCompressionDecorator
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 ofmeta info snapshots
for this state snapshot.
-
createKVStateIterator
KeyValueStateIterator createKVStateIterator() throws IOException
Returns aKeyValueStateIterator
for iterating over all key-value states for this snapshot resources.- Throws:
IOException
-
getKeyGroupRange
KeyGroupRange getKeyGroupRange()
Returns theKeyGroupRange
of this snapshot.
-
getKeySerializer
TypeSerializer<K> getKeySerializer()
Returns keyTypeSerializer
.
-
getStreamCompressionDecorator
StreamCompressionDecorator getStreamCompressionDecorator()
Returns theStreamCompressionDecorator
that should be used for writing.
-
-