Constructor and Description |
---|
AggCombiner(WindowTimerService<Long> timerService,
StateKeyContext keyContext,
WindowValueState<Long> accState,
NamespaceAggsHandleFunction<Long> aggregator,
boolean isEventTime) |
GlobalAggCombiner(WindowTimerService<Long> timerService,
StateKeyContext keyContext,
WindowValueState<Long> accState,
NamespaceAggsHandleFunction<Long> localAggregator,
NamespaceAggsHandleFunction<Long> globalAggregator) |
Constructor and Description |
---|
RowTimeDeduplicateRecordsCombiner(WindowTimerService<Long> timerService,
StateKeyContext keyContext,
WindowValueState<Long> dataState,
int rowtimeIndex,
boolean keepLastRow,
TypeSerializer<RowData> recordSerializer) |
Constructor and Description |
---|
TopNRecordsCombiner(WindowTimerService<Long> timerService,
StateKeyContext keyContext,
WindowMapState<Long,List<RowData>> dataState,
Comparator<RowData> sortKeyComparator,
KeySelector<RowData,RowData> sortKeySelector,
long topN,
TypeSerializer<RowData> recordSerializer,
boolean isEventTime) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.