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

Packages that use RowDataKeySelector

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

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

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

Modifier and Type	Method and Description
static RowDataKeySelector	KeySelectorUtil.getRowDataSelector(ClassLoader classLoader, int[] keyFields, InternalTypeInfo<RowData> rowType)
static RowDataKeySelector	KeySelectorUtil.getRowDataSelector(ClassLoader classLoader, int[] keyFields, InternalTypeInfo<RowData> rowType, Class<? extends RowData> outClass) Create a RowDataKeySelector to extract keys from DataStream which type is InternalTypeInfo of RowData.

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

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

Modifier and Type	Class and Description
class	BinaryRowDataKeySelector A KeySelector which will extract key from RowData.
class	EmptyRowDataKeySelector A utility class which key is always empty no matter what the input row is.
class	GenericRowDataKeySelector A KeySelector which will extract key from RowData.

Uses of RowDataKeySelector in org.apache.flink.table.runtime.operators.aggregate.window

Constructors in org.apache.flink.table.runtime.operators.aggregate.window with parameters of type RowDataKeySelector

Constructor and Description
LocalSlicingWindowAggOperator(RowDataKeySelector keySelector, SliceAssigner sliceAssigner, WindowBuffer.LocalFactory windowBufferFactory, ZoneId shiftTimezone)

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

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

Constructor and Description
AppendOnlyFirstNFunction(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, GeneratedRecordComparator sortKeyGeneratedRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber)
AppendOnlyTopNFunction(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, GeneratedRecordComparator sortKeyGeneratedRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber, long cacheSize)
FastTop1Function(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, GeneratedRecordComparator generatedSortKeyComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber, long cacheSize)
RetractableTopNFunction(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, ComparableRecordComparator comparableRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, GeneratedRecordEqualiser generatedEqualiser, boolean generateUpdateBefore, boolean outputRankNumber)
UpdatableTopNFunction(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, RowDataKeySelector rowKeySelector, GeneratedRecordComparator generatedRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber, long cacheSize)

Uses of RowDataKeySelector in org.apache.flink.table.runtime.operators.rank.window

Methods in org.apache.flink.table.runtime.operators.rank.window with parameters of type RowDataKeySelector

Modifier and Type	Method and Description
WindowRankOperatorBuilder	WindowRankOperatorBuilder.sortKeySelector(RowDataKeySelector sortKeySelector)

Uses of RowDataKeySelector in org.apache.flink.table.runtime.operators.rank.window.combines

Constructors in org.apache.flink.table.runtime.operators.rank.window.combines with parameters of type RowDataKeySelector

Constructor and Description
Factory(GeneratedRecordComparator genSortKeyComparator, RowDataKeySelector sortKeySelector, TypeSerializer<RowData> recordSerializer, long topN)