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

Class AsyncStateRecordsWindowBuffer.Factory

java.lang.Object

org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers.AsyncStateRecordsWindowBuffer.Factory

All Implemented Interfaces:

Serializable, AsyncStateWindowBuffer.Factory

Enclosing class:

AsyncStateRecordsWindowBuffer

public static final class AsyncStateRecordsWindowBuffer.Factory
extends Object
implements AsyncStateWindowBuffer.Factory

Factory to create AsyncStateRecordsWindowBuffer with AsyncStateRecordsCombiner.Factory.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
Factory(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSer, AsyncStateRecordsCombiner.Factory combinerFactory, GeneratedRecordEqualiser generatedKeyEqualiser)

Method Summary

Modifier and Type	Method	Description
AsyncStateWindowBuffer	create(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, AsyncStateKeyContext keyContext, WindowAsyncState<Long> windowState, boolean isEventTime, ZoneId shiftTimeZone)	Creates a WindowBuffer 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

Factory

public Factory(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer,
               AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSer,
               AsyncStateRecordsCombiner.Factory combinerFactory,
               GeneratedRecordEqualiser generatedKeyEqualiser)

Method Detail

create

public AsyncStateWindowBuffer create(Object operatorOwner,
                                     org.apache.flink.runtime.memory.MemoryManager memoryManager,
                                     long memorySize,
                                     org.apache.flink.api.common.functions.RuntimeContext runtimeContext,
                                     WindowTimerService<Long> timerService,
                                     AsyncStateKeyContext keyContext,
                                     WindowAsyncState<Long> windowState,
                                     boolean isEventTime,
                                     ZoneId shiftTimeZone)
                              throws Exception

Description copied from interface: AsyncStateWindowBuffer.Factory

Creates a WindowBuffer that buffers elements in memory before flushing.

Specified by:

create in interface AsyncStateWindowBuffer.Factory

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

runtimeContext - the current RuntimeContext

timerService - the service to register event-time and processing-time timers

keyContext - the state context to accessing states

windowState - the window async state to flush buffered data into.

isEventTime - indicates whether the operator works in event-time or processing-time mode, used for register corresponding timers.

shiftTimeZone - the shift timezone of the window

Throws:

IOException - thrown if the buffer can't be opened

Exception