public class AggCombiner extends Object implements RecordsCombiner
RecordsCombiner
that accumulates input records into the window
accumulator state.Modifier and Type | Class and Description |
---|---|
static class |
AggCombiner.Factory
Factory to create
AggCombiner . |
RecordsCombiner.LocalFactory
Constructor and Description |
---|
AggCombiner(WindowTimerService<Long> timerService,
StateKeyContext keyContext,
WindowValueState<Long> accState,
NamespaceAggsHandleFunction<Long> aggregator,
boolean isEventTime) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Release resources allocated by this combine function.
|
void |
combine(WindowKey windowKey,
Iterator<RowData> records)
Combines the buffered data into state based on the given window-key pair.
|
public AggCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowValueState<Long> accState, NamespaceAggsHandleFunction<Long> aggregator, boolean isEventTime)
public void combine(WindowKey windowKey, Iterator<RowData> records) throws Exception
RecordsCombiner
combine
in interface RecordsCombiner
windowKey
- the window-key pair that the buffered data belong to, the window-key object
is reused.records
- the buffered data, the iterator and RowData
objects are reused.Exception
public void close() throws Exception
RecordsCombiner
close
in interface RecordsCombiner
Exception
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.