Uses of Class
org.apache.flink.table.runtime.operators.rank.TopNBuffer
-
Packages that use TopNBuffer Package Description org.apache.flink.table.runtime.operators.rank org.apache.flink.table.runtime.operators.rank.utils -
-
Uses of TopNBuffer in org.apache.flink.table.runtime.operators.rank
Methods in org.apache.flink.table.runtime.operators.rank with parameters of type TopNBuffer Modifier and Type Method Description protected booleanAbstractTopNFunction. checkSortKeyInBufferRange(org.apache.flink.table.data.RowData sortKey, TopNBuffer buffer)Checks whether the record should be put into the buffer. -
Uses of TopNBuffer in org.apache.flink.table.runtime.operators.rank.utils
Methods in org.apache.flink.table.runtime.operators.rank.utils that return TopNBuffer Modifier and Type Method Description TopNBufferAppendOnlyTopNHelper. getTopNBufferFromCache(org.apache.flink.table.data.RowData currentKey)Methods in org.apache.flink.table.runtime.operators.rank.utils with parameters of type TopNBuffer Modifier and Type Method Description voidAppendOnlyTopNHelper. processElementWithoutRowNumber(TopNBuffer buffer, org.apache.flink.table.data.RowData input, long rankEnd, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)voidAppendOnlyTopNHelper. processElementWithRowNumber(TopNBuffer buffer, org.apache.flink.table.data.RowData sortKey, org.apache.flink.table.data.RowData input, long rankEnd, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)The without-number-algorithm can't handle topN with offset, so use the with-number-algorithm to handle offset.voidAppendOnlyTopNHelper. saveTopNBufferToCache(org.apache.flink.table.data.RowData currentKey, TopNBuffer topNBuffer)
-