Uses of Interface
org.apache.flink.state.changelog.restore.StateChangeApplier
-
Packages that use StateChangeApplier Package Description org.apache.flink.state.changelog org.apache.flink.state.changelog.restore -
-
Uses of StateChangeApplier in org.apache.flink.state.changelog
Methods in org.apache.flink.state.changelog that return StateChangeApplier Modifier and Type Method Description StateChangeApplierChangelogKeyGroupedPriorityQueue. getChangeApplier(ChangelogApplierFactory factory)StateChangeApplierChangelogState. getChangeApplier(ChangelogApplierFactory factory) -
Uses of StateChangeApplier in org.apache.flink.state.changelog.restore
Methods in org.apache.flink.state.changelog.restore that return StateChangeApplier Modifier and Type Method Description <T> StateChangeApplierChangelogApplierFactory. forPriorityQueue(org.apache.flink.runtime.state.KeyGroupedInternalPriorityQueue<T> priorityQueue, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer)
-