Uses of Class
org.apache.flink.table.runtime.operators.window.state.WindowValueState

Packages that use WindowValueState

Package	Description
org.apache.flink.table.runtime.operators.aggregate.window.combines
org.apache.flink.table.runtime.operators.aggregate.window.processors
org.apache.flink.table.runtime.operators.deduplicate.window.combines

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 and 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 and Description
protected WindowValueState<Long>	AbstractWindowAggProcessor.windowState state schema: [key, window_end, 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 and Description
RowTimeDeduplicateRecordsCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowValueState<Long> dataState, int rowtimeIndex, boolean keepLastRow, TypeSerializer<RowData> recordSerializer)