Package org.apache.flink.table.runtime.operators.rank.window.combines
-
Class Summary Class Description TopNRecordsCombiner An implementation ofRecordsCombiner
that save topN records of incremental input records into the window state.TopNRecordsCombiner.Factory Factory to createTopNRecordsCombiner
.