Uses of Interface
org.apache.flink.table.runtime.operators.aggregate.window.buffers.WindowBuffer.Factory

Packages that use WindowBuffer.Factory

Package	Description
org.apache.flink.table.runtime.operators.aggregate.window.buffers
org.apache.flink.table.runtime.operators.aggregate.window.processors
org.apache.flink.table.runtime.operators.deduplicate.window.processors
org.apache.flink.table.runtime.operators.rank.window.processors

Uses of WindowBuffer.Factory in org.apache.flink.table.runtime.operators.aggregate.window.buffers

Classes in org.apache.flink.table.runtime.operators.aggregate.window.buffers that implement WindowBuffer.Factory

Modifier and Type	Class and Description
static class	RecordsWindowBuffer.Factory Factory to create RecordsWindowBuffer with RecordsCombiner.Factory.

Uses of WindowBuffer.Factory in org.apache.flink.table.runtime.operators.aggregate.window.processors

Fields in org.apache.flink.table.runtime.operators.aggregate.window.processors declared as WindowBuffer.Factory

Modifier and Type	Field and Description
protected WindowBuffer.Factory	AbstractWindowAggProcessor.windowBufferFactory

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

Constructor and Description
AbstractWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, WindowBuffer.Factory bufferFactory, SliceAssigner sliceAssigner, TypeSerializer<RowData> accSerializer, java.time.ZoneId shiftTimeZone)
SliceSharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, WindowBuffer.Factory bufferFactory, SliceSharedAssigner sliceAssigner, TypeSerializer<RowData> accSerializer, int indexOfCountStar, java.time.ZoneId shiftTimeZone)
SliceUnsharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, WindowBuffer.Factory windowBufferFactory, SliceUnsharedAssigner sliceAssigner, TypeSerializer<RowData> accSerializer, java.time.ZoneId shiftTimeZone)

Uses of WindowBuffer.Factory in org.apache.flink.table.runtime.operators.deduplicate.window.processors

Constructors in org.apache.flink.table.runtime.operators.deduplicate.window.processors with parameters of type WindowBuffer.Factory

Constructor and Description
RowTimeWindowDeduplicateProcessor(TypeSerializer<RowData> inputSerializer, WindowBuffer.Factory bufferFactory, int windowEndIndex, java.time.ZoneId shiftTimeZone)

Uses of WindowBuffer.Factory in org.apache.flink.table.runtime.operators.rank.window.processors

Constructors in org.apache.flink.table.runtime.operators.rank.window.processors with parameters of type WindowBuffer.Factory

Constructor and Description
WindowRankProcessor(TypeSerializer<RowData> inputSerializer, GeneratedRecordComparator genSortKeyComparator, TypeSerializer<RowData> sortKeySerializer, WindowBuffer.Factory bufferFactory, long rankStart, long rankEnd, boolean outputRankNumber, int windowEndIndex, java.time.ZoneId shiftTimeZone)