Uses of Class
org.apache.flink.table.runtime.operators.rank.AbstractTopNFunction
-
-
Uses of AbstractTopNFunction in org.apache.flink.table.runtime.operators.rank
Subclasses of AbstractTopNFunction in org.apache.flink.table.runtime.operators.rank Modifier and Type Class Description classAbstractSyncStateTopNFunctionBase class for TopN Function with sync state api.classAppendOnlyFirstNFunctionA variant ofAppendOnlyTopNFunctionto handle first-n case.classAppendOnlyTopNFunctionA TopN function could handle insert-only stream.classFastTop1FunctionA more concise implementation forAppendOnlyTopNFunctionandUpdatableTopNFunctionwhen only Top-1 is desired.classRetractableTopNFunctionA TopN function could handle updating stream.classUpdatableTopNFunctionA TopN function could handle updating stream.Fields in org.apache.flink.table.runtime.operators.rank declared as AbstractTopNFunction Modifier and Type Field Description protected AbstractTopNFunctionAbstractTopNFunction.AbstractTopNHelper. topNFunctionConstructors in org.apache.flink.table.runtime.operators.rank with parameters of type AbstractTopNFunction Constructor Description AbstractTopNHelper(AbstractTopNFunction topNFunction) -
Uses of AbstractTopNFunction in org.apache.flink.table.runtime.operators.rank.async
Subclasses of AbstractTopNFunction in org.apache.flink.table.runtime.operators.rank.async Modifier and Type Class Description classAbstractAsyncStateTopNFunctionBase class for TopN Function with async state api.classAsyncStateAppendOnlyTopNFunctionA TopN function could handle insert-only stream.classAsyncStateFastTop1FunctionA more concise implementation forAppendOnlyTopNFunctionandUpdatableTopNFunctionwhen only Top-1 is desired. -
Uses of AbstractTopNFunction in org.apache.flink.table.runtime.operators.rank.utils
Constructors in org.apache.flink.table.runtime.operators.rank.utils with parameters of type AbstractTopNFunction Constructor Description AppendOnlyTopNHelper(AbstractTopNFunction topNFunction, long cacheSize, long topNSize)FastTop1Helper(AbstractTopNFunction topNFunction, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> inputRowSer, long cacheSize, long topNSize)
-