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

Class RecordsWindowBuffer.LocalFactory

java.lang.Object

org.apache.flink.table.runtime.operators.aggregate.window.buffers.RecordsWindowBuffer.LocalFactory

All Implemented Interfaces:

Serializable, WindowBuffer.LocalFactory

Enclosing class:

RecordsWindowBuffer

public static final class RecordsWindowBuffer.LocalFactory
extends Object
implements WindowBuffer.LocalFactory

Factory to create RecordsWindowBuffer with RecordsCombiner.LocalFactory.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LocalFactory(PagedTypeSerializer<RowData> keySer, AbstractRowDataSerializer<RowData> inputSer, RecordsCombiner.LocalFactory localFactory)

Method Summary

Modifier and Type	Method and Description
WindowBuffer	create(Object operatorOwner, MemoryManager memoryManager, long memorySize, RuntimeContext runtimeContext, Collector<RowData> collector, ZoneId shiftTimeZone) Creates a WindowBuffer for local window that buffers elements in memory before flushing.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalFactory

public LocalFactory(PagedTypeSerializer<RowData> keySer,
                    AbstractRowDataSerializer<RowData> inputSer,
                    RecordsCombiner.LocalFactory localFactory)

Method Detail

create

public WindowBuffer create(Object operatorOwner,
                           MemoryManager memoryManager,
                           long memorySize,
                           RuntimeContext runtimeContext,
                           Collector<RowData> collector,
                           ZoneId shiftTimeZone)
                    throws Exception

Description copied from interface: WindowBuffer.LocalFactory

Creates a WindowBuffer for local window that buffers elements in memory before flushing.

Specified by:

create in interface WindowBuffer.LocalFactory

Parameters:

operatorOwner - the owner of the operator

memoryManager - the manager that governs memory by Flink framework

memorySize - the managed memory size can be used by this operator

collector - collector to emit records

shiftTimeZone - the shift timezone of the window

Throws:

IOException - thrown if the buffer can't be opened

Exception