Package org.apache.flink.table.runtime.operators.rank.async
-
Class Summary Class Description AbstractAsyncStateTopNFunction Base class for TopN Function with async state api.AsyncStateAppendOnlyTopNFunction A TopN function could handle insert-only stream.AsyncStateFastTop1Function A more concise implementation forAppendOnlyTopNFunctionandUpdatableTopNFunctionwhen only Top-1 is desired.