@FunctionalInterface public static interface WindowBuffer.LocalFactory extends Serializable
WindowBuffer
.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. |
WindowBuffer create(Object operatorOwner, MemoryManager memoryManager, long memorySize, RuntimeContext runtimeContext, Collector<RowData> collector, ZoneId shiftTimeZone) throws Exception
WindowBuffer
for local window that buffers elements in memory before
flushing.operatorOwner
- the owner of the operatormemoryManager
- the manager that governs memory by Flink frameworkmemorySize
- the managed memory size can be used by this operatorcollector
- collector to emit recordsshiftTimeZone
- the shift timezone of the windowIOException
- thrown if the buffer can't be openedException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.