Package | Description |
---|---|
org.apache.flink.table.runtime.operators.rank.window.combines |
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.