Uses of Class
org.apache.flink.state.changelog.ChangelogKeyGroupedPriorityQueue
-
Packages that use ChangelogKeyGroupedPriorityQueue Package Description org.apache.flink.state.changelog -
-
Uses of ChangelogKeyGroupedPriorityQueue in org.apache.flink.state.changelog
Methods in org.apache.flink.state.changelog that return ChangelogKeyGroupedPriorityQueue Modifier and Type Method Description <T> ChangelogKeyGroupedPriorityQueue<T>ChangelogStateFactory. create(String stateName, org.apache.flink.runtime.state.KeyGroupedInternalPriorityQueue<T> internalPriorityQueue, StateChangeLogger<T,Void> logger, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer)
-