Uses of Interface
org.apache.flink.table.runtime.keyselector.BaseRowKeySelector

Packages that use BaseRowKeySelector

Package	Description
org.apache.flink.table.planner.plan.utils
org.apache.flink.table.runtime.keyselector
org.apache.flink.table.runtime.operators.rank

Uses of BaseRowKeySelector in org.apache.flink.table.planner.plan.utils

Methods in org.apache.flink.table.planner.plan.utils that return BaseRowKeySelector

Modifier and Type	Method and Description
static BaseRowKeySelector	KeySelectorUtil.getBaseRowSelector(int[] keyFields, BaseRowTypeInfo rowType) Create a BaseRowKeySelector to extract keys from DataStream which type is BaseRowTypeInfo.

Uses of BaseRowKeySelector in org.apache.flink.table.runtime.keyselector

Classes in org.apache.flink.table.runtime.keyselector that implement BaseRowKeySelector

Modifier and Type	Class and Description
class	BinaryRowKeySelector A KeySelector which will extract key from BaseRow.
class	NullBinaryRowKeySelector A utility class which key is always empty no matter what the input row is.

Uses of BaseRowKeySelector in org.apache.flink.table.runtime.operators.rank

Constructors in org.apache.flink.table.runtime.operators.rank with parameters of type BaseRowKeySelector

Constructor and Description
AppendOnlyTopNFunction(long minRetentionTime, long maxRetentionTime, BaseRowTypeInfo inputRowType, GeneratedRecordComparator sortKeyGeneratedRecordComparator, BaseRowKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateRetraction, boolean outputRankNumber, long cacheSize)
RetractableTopNFunction(long minRetentionTime, long maxRetentionTime, BaseRowTypeInfo inputRowType, GeneratedRecordComparator generatedRecordComparator, BaseRowKeySelector sortKeySelector, RankType rankType, RankRange rankRange, GeneratedRecordEqualiser generatedEqualiser, boolean generateRetraction, boolean outputRankNumber)
UpdatableTopNFunction(long minRetentionTime, long maxRetentionTime, BaseRowTypeInfo inputRowType, BaseRowKeySelector rowKeySelector, GeneratedRecordComparator generatedRecordComparator, BaseRowKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateRetraction, boolean outputRankNumber, long cacheSize)