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

Interface Summary

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

Class Summary

Class	Description
RecordsWindowBuffer	An implementation of WindowBuffer that buffers input elements in a WindowBytesMultiMap and combines buffered elements into state when flushing.
RecordsWindowBuffer.Factory	Factory to create RecordsWindowBuffer with RecordsCombiner.Factory.
RecordsWindowBuffer.LocalFactory	Factory to create RecordsWindowBuffer with RecordsCombiner.LocalFactory.