org.apache.flink.table.runtime.operators.aggregate.asyncwindow.combines (Flink : Table : Runtime 2.1.2-cp1 API)

Class Summary
Class	Description
AsyncStateAggCombiner	An implementation of `RecordsCombiner` that accumulates input records into the window accumulator with async state.
AsyncStateAggCombiner.Factory	Factory to create `AsyncStateAggCombiner`.

Package org.apache.flink.table.runtime.operators.aggregate.asyncwindow.combines