Uses of Interface
org.apache.flink.state.changelog.StateChangeLogger
-
Packages that use StateChangeLogger Package Description org.apache.flink.state.changelog -
-
Uses of StateChangeLogger in org.apache.flink.state.changelog
Subinterfaces of StateChangeLogger in org.apache.flink.state.changelog Modifier and Type Interface Description interfaceKvStateChangeLogger<Value,Namespace>A logger for some key-partitioned state (not onlyValueState.Methods in org.apache.flink.state.changelog that return StateChangeLogger Modifier and Type Method Description StateChangeLogger<T,Void>ChangelogKeyGroupedPriorityQueue. getStateChangeLogger()Methods in org.apache.flink.state.changelog with parameters of type StateChangeLogger Modifier and Type Method Description <T> ChangelogKeyGroupedPriorityQueue<T>ChangelogStateFactory. create(String stateName, KeyGroupedInternalPriorityQueue<T> internalPriorityQueue, StateChangeLogger<T,Void> logger, TypeSerializer<T> serializer)Constructors in org.apache.flink.state.changelog with parameters of type StateChangeLogger Constructor Description ChangelogKeyGroupedPriorityQueue(KeyGroupedInternalPriorityQueue<T> delegatedPriorityQueue, StateChangeLogger<T,Void> logger, TypeSerializer<T> serializer)
-