Uses of Interface
org.apache.flink.table.runtime.operators.window.tvf.state.StateKeyContext
-
-
Uses of StateKeyContext in org.apache.flink.table.runtime.operators.aggregate.window.combines
Constructors in org.apache.flink.table.runtime.operators.aggregate.window.combines with parameters of type StateKeyContext Constructor Description AggCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowValueState<Long> accState, NamespaceAggsHandleFunction<Long> aggregator, boolean isEventTime)GlobalAggCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowValueState<Long> accState, NamespaceAggsHandleFunction<Long> localAggregator, NamespaceAggsHandleFunction<Long> globalAggregator) -
Uses of StateKeyContext in org.apache.flink.table.runtime.operators.deduplicate.window.combines
Constructors in org.apache.flink.table.runtime.operators.deduplicate.window.combines with parameters of type StateKeyContext Constructor Description RowTimeDeduplicateRecordsCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowValueState<Long> dataState, int rowtimeIndex, boolean keepLastRow, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> recordSerializer) -
Uses of StateKeyContext in org.apache.flink.table.runtime.operators.rank.window.combines
Constructors in org.apache.flink.table.runtime.operators.rank.window.combines with parameters of type StateKeyContext Constructor Description TopNRecordsCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowMapState<Long,List<org.apache.flink.table.data.RowData>> dataState, Comparator<org.apache.flink.table.data.RowData> sortKeyComparator, org.apache.flink.api.java.functions.KeySelector<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData> sortKeySelector, long topN, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> recordSerializer, boolean isEventTime)
-