Package | Description |
---|---|
org.apache.flink.table.runtime.operators.aggregate.window.buffers | |
org.apache.flink.table.runtime.operators.aggregate.window.processors |
Modifier and Type | Class and Description |
---|---|
class |
RecordsWindowBuffer
An implementation of
WindowBuffer that buffers input elements in a WindowBytesMultiMap and combines buffered elements into state when flushing. |
Modifier and Type | Method and Description |
---|---|
WindowBuffer |
WindowBuffer.LocalFactory.create(Object operatorOwner,
MemoryManager memoryManager,
long memorySize,
RuntimeContext runtimeContext,
Collector<RowData> collector,
java.time.ZoneId shiftTimeZone)
Creates a
WindowBuffer for local window that buffers elements in memory before
flushing. |
WindowBuffer |
RecordsWindowBuffer.LocalFactory.create(Object operatorOwner,
MemoryManager memoryManager,
long memorySize,
RuntimeContext runtimeContext,
Collector<RowData> collector,
java.time.ZoneId shiftTimeZone) |
WindowBuffer |
WindowBuffer.Factory.create(Object operatorOwner,
MemoryManager memoryManager,
long memorySize,
RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime,
java.time.ZoneId shiftTimeZone)
Creates a
WindowBuffer that buffers elements in memory before flushing. |
WindowBuffer |
RecordsWindowBuffer.Factory.create(Object operatorOwner,
MemoryManager memoryManager,
long memorySize,
RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime,
java.time.ZoneId shiftTimeZone) |
Modifier and Type | Field and Description |
---|---|
protected WindowBuffer |
AbstractWindowAggProcessor.windowBuffer |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.