Class HeapPriorityQueueStateSnapshot<T>
- java.lang.Object
-
- org.apache.flink.runtime.state.heap.HeapPriorityQueueStateSnapshot<T>
-
- Type Parameters:
T
- type of the state elements.
- All Implemented Interfaces:
StateSnapshot
public class HeapPriorityQueueStateSnapshot<T> extends Object implements StateSnapshot
This class represents the snapshot of anHeapPriorityQueueSet
.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.flink.runtime.state.StateSnapshot
StateSnapshot.StateKeyGroupWriter
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Iterator<T>
getIteratorForKeyGroup(int keyGroupId)
StateSnapshot.StateKeyGroupWriter
getKeyGroupWriter()
This method returnsStateSnapshot.StateKeyGroupWriter
and should be called in the asynchronous part of the snapshot.RegisteredPriorityQueueStateBackendMetaInfo<T>
getMetaInfo()
StateMetaInfoSnapshot
getMetaInfoSnapshot()
Returns a snapshot of the state's meta data.void
release()
Release the snapshot.
-
-
-
Method Detail
-
getKeyGroupWriter
@Nonnull public StateSnapshot.StateKeyGroupWriter getKeyGroupWriter()
Description copied from interface:StateSnapshot
This method returnsStateSnapshot.StateKeyGroupWriter
and should be called in the asynchronous part of the snapshot.- Specified by:
getKeyGroupWriter
in interfaceStateSnapshot
-
getMetaInfoSnapshot
@Nonnull public StateMetaInfoSnapshot getMetaInfoSnapshot()
Description copied from interface:StateSnapshot
Returns a snapshot of the state's meta data.- Specified by:
getMetaInfoSnapshot
in interfaceStateSnapshot
-
getMetaInfo
@Nonnull public RegisteredPriorityQueueStateBackendMetaInfo<T> getMetaInfo()
-
release
public void release()
Description copied from interface:StateSnapshot
Release the snapshot. All snapshots should be released when they are no longer used because some implementation can only release resources after a release. ProducedStateSnapshot.StateKeyGroupWriter
should no longer be used after calling this method.- Specified by:
release
in interfaceStateSnapshot
-
-