@FunctionalInterface public static interface WindowBuffer.LocalFactory extends Serializable
|Modifier and Type||Method and Description|
WindowBuffer create(Object operatorOwner, MemoryManager memoryManager, long memorySize, RuntimeContext runtimeContext, Collector<RowData> collector, java.time.ZoneId shiftTimeZone) throws Exception
WindowBufferfor local window that buffers elements in memory before flushing.
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 shit timezone of the window
IOException- thrown if the buffer can't be opened
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.