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

Interface Summary

Interface	Description
AsyncStateWindowBuffer	A buffer that buffers data in memory and flushes many values to async state together at a time to avoid frequently accessing async state, or flushes to output to reduce shuffling data.
AsyncStateWindowBuffer.Factory	A factory that creates a WindowBuffer with async state.

Class Summary

Class	Description
AsyncStateRecordsWindowBuffer	An implementation of AsyncStateWindowBuffer that buffers input elements in a WindowBytesMultiMap and combines buffered elements into async state when flushing.
AsyncStateRecordsWindowBuffer.Factory	Factory to create AsyncStateRecordsWindowBuffer with AsyncStateRecordsCombiner.Factory.