Constructor and Description |
---|
RecordsWindowBuffer(Object operatorOwner,
MemoryManager memoryManager,
long memorySize,
RecordsCombiner combineFunction,
PagedTypeSerializer<RowData> keySer,
AbstractRowDataSerializer<RowData> inputSer,
boolean requiresCopy,
java.time.ZoneId shiftTimeZone) |
Modifier and Type | Class and Description |
---|---|
class |
AggCombiner
An implementation of
RecordsCombiner that accumulates input records into the window
accumulator state. |
class |
GlobalAggCombiner
An implementation of
RecordsCombiner that accumulates local accumulators records into the
window accumulator state. |
class |
LocalAggCombiner
An implementation of
RecordsCombiner that accumulates input records into local
accumulators. |
Modifier and Type | Method and Description |
---|---|
RecordsCombiner |
LocalAggCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
Collector<RowData> collector) |
RecordsCombiner |
AggCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime) |
RecordsCombiner |
GlobalAggCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime) |
Modifier and Type | Class and Description |
---|---|
class |
TopNRecordsCombiner
An implementation of
RecordsCombiner that save topN records of incremental input records
into the window state. |
Modifier and Type | Method and Description |
---|---|
RecordsCombiner |
TopNRecordsCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime) |
Modifier and Type | Method and Description |
---|---|
RecordsCombiner |
RecordsCombiner.LocalFactory.createRecordsCombiner(RuntimeContext runtimeContext,
Collector<RowData> collector) |
RecordsCombiner |
RecordsCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext,
WindowTimerService<Long> timerService,
KeyedStateBackend<RowData> stateBackend,
WindowState<Long> windowState,
boolean isEventTime)
Creates a
RecordsCombiner that can combine buffered data into states. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.