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

Packages that use WindowBuffer

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

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

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

Modifier and Type	Class	Description
class	RecordsWindowBuffer	An implementation of WindowBuffer that buffers input elements in a WindowBytesMultiMap and combines buffered elements into state when flushing.

Methods in org.apache.flink.table.runtime.operators.aggregate.window.buffers that return WindowBuffer

Modifier and Type	Method	Description
WindowBuffer	RecordsWindowBuffer.Factory.create(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime, java.time.ZoneId shiftTimeZone)
WindowBuffer	RecordsWindowBuffer.LocalFactory.create(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> collector, java.time.ZoneId shiftTimeZone)
WindowBuffer	WindowBuffer.Factory.create(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime, java.time.ZoneId shiftTimeZone)	Creates a WindowBuffer that buffers elements in memory before flushing.
WindowBuffer	WindowBuffer.LocalFactory.create(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> collector, java.time.ZoneId shiftTimeZone)	Creates a WindowBuffer for local window that buffers elements in memory before flushing.

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

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

Modifier and Type	Field	Description
protected WindowBuffer	AbstractWindowAggProcessor.windowBuffer