Package org.apache.flink.table.runtime.operators.rank

Interface Summary

Interface	Description
RankRange	RankRange for Rank, including following 3 types : ConstantRankRange, ConstantRankRangeWithoutEnd, VariableRankRange.

Class Summary

Class	Description
AbstractSyncStateTopNFunction	Base class for TopN Function with sync state api.
AbstractTopNFunction	Base class for TopN Function.
AbstractTopNFunction.AbstractTopNHelper	An abstract helper to do the logic Top-n used for all top-n functions.
AppendOnlyFirstNFunction	A variant of AppendOnlyTopNFunction to handle first-n case.
AppendOnlyTopNFunction	A TopN function could handle insert-only stream.
ComparableRecordComparator	Because it's impossible to restore a RecordComparator instance generated by GeneratedRecordComparator from checkpoint snapshot.
ConstantRankRange	rankStart and rankEnd are inclusive, rankStart always start from one.
ConstantRankRangeWithoutEnd	ConstantRankRangeWithoutEnd is a RankRange which not specify RankEnd.
FastTop1Function	A more concise implementation for AppendOnlyTopNFunction and UpdatableTopNFunction when only Top-1 is desired.
RetractableTopNFunction	A TopN function could handle updating stream.
TopNBuffer	TopNBuffer stores mapping from sort key to records list, sortKey is RowData type, each record is RowData type.
TopNBufferCacheRemovalListener<V>	A common cache removal listener for rank node.
UpdatableTopNFunction	A TopN function could handle updating stream.
VariableRankRange	changing rank limit depends on input.

Enum Summary

Enum	Description
RankType	An enumeration of rank type, usable to show how exactly generate rank number.