Uses of Interface
org.apache.flink.table.runtime.keyselector.RowDataKeySelector
-
-
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 Description classBinaryRowDataKeySelectorA KeySelector which will extract key from RowData.classEmptyRowDataKeySelectorA utility class which key is always empty no matter what the input row is.classGenericRowDataKeySelectorA 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 Description LocalSlicingWindowAggOperator(RowDataKeySelector keySelector, SliceAssigner sliceAssigner, WindowBuffer.LocalFactory windowBufferFactory, java.time.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 Description AppendOnlyFirstNFunction(org.apache.flink.api.common.state.StateTtlConfig ttlConfig, InternalTypeInfo<org.apache.flink.table.data.RowData> inputRowType, GeneratedRecordComparator sortKeyGeneratedRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber)AppendOnlyTopNFunction(org.apache.flink.api.common.state.StateTtlConfig ttlConfig, InternalTypeInfo<org.apache.flink.table.data.RowData> inputRowType, GeneratedRecordComparator sortKeyGeneratedRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber, long cacheSize)FastTop1Function(org.apache.flink.api.common.state.StateTtlConfig ttlConfig, InternalTypeInfo<org.apache.flink.table.data.RowData> inputRowType, GeneratedRecordComparator generatedSortKeyComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber, long cacheSize)RetractableTopNFunction(org.apache.flink.api.common.state.StateTtlConfig ttlConfig, InternalTypeInfo<org.apache.flink.table.data.RowData> inputRowType, ComparableRecordComparator comparableRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, GeneratedRecordEqualiser generatedEqualiser, boolean generateUpdateBefore, boolean outputRankNumber)UpdatableTopNFunction(org.apache.flink.api.common.state.StateTtlConfig ttlConfig, InternalTypeInfo<org.apache.flink.table.data.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 Description WindowRankOperatorBuilderWindowRankOperatorBuilder. 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 Description Factory(GeneratedRecordComparator genSortKeyComparator, RowDataKeySelector sortKeySelector, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> recordSerializer, long topN)
-