Uses of Class
org.apache.flink.table.runtime.operators.window.async.tvf.state.WindowAsyncValueState
-
-
Uses of WindowAsyncValueState in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.combines
Constructors in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.combines with parameters of type WindowAsyncValueState Constructor Description AsyncStateAggCombiner(WindowTimerService<Long> timerService, WindowAsyncValueState<Long> accState, NamespaceAggsHandleFunction<Long> aggregator, boolean isEventTime) -
Uses of WindowAsyncValueState in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors
Fields in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors declared as WindowAsyncValueState Modifier and Type Field Description protected WindowAsyncValueState<W>AbstractAsyncStateWindowAggProcessor. windowStatestate schema: [key, window, accumulator].
-