Uses of Class
org.apache.flink.table.runtime.operators.window.tvf.state.WindowValueState
-
-
Uses of WindowValueState 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 WindowValueState 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 WindowValueState in org.apache.flink.table.runtime.operators.aggregate.window.processors
Fields in org.apache.flink.table.runtime.operators.aggregate.window.processors declared as WindowValueState Modifier and Type Field Description protected WindowValueState<W>AbstractSyncStateWindowAggProcessor. windowStatestate schema: [key, window, accumulator]. -
Uses of WindowValueState 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 WindowValueState 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)
-