Uses of Interface
org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers.AsyncStateWindowBuffer.Factory

Packages that use AsyncStateWindowBuffer.Factory

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

Uses of AsyncStateWindowBuffer.Factory in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers

Classes in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers that implement AsyncStateWindowBuffer.Factory

Modifier and Type	Class	Description
static class	AsyncStateRecordsWindowBuffer.Factory	Factory to create AsyncStateRecordsWindowBuffer with AsyncStateRecordsCombiner.Factory.

Uses of AsyncStateWindowBuffer.Factory in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors

Fields in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors declared as AsyncStateWindowBuffer.Factory

Modifier and Type	Field	Description
protected AsyncStateWindowBuffer.Factory	AbstractAsyncStateSliceWindowAggProcessor.windowBufferFactory

Constructors in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors with parameters of type AsyncStateWindowBuffer.Factory

Constructor	Description
AbstractAsyncStateSliceWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, AsyncStateWindowBuffer.Factory bufferFactory, SliceAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, int indexOfCountStar, ZoneId shiftTimeZone)
AsyncStateSliceSharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, AsyncStateWindowBuffer.Factory bufferFactory, SliceSharedAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, int indexOfCountStar, ZoneId shiftTimeZone)
AsyncStateSliceUnsharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, AsyncStateWindowBuffer.Factory windowBufferFactory, SliceUnsharedAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, int indexOfCountStar, ZoneId shiftTimeZone)