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

Packages that use RowDataKeySelector

Package	Description
org.apache.flink.table.runtime.keyselector
org.apache.flink.table.runtime.operators
org.apache.flink.table.runtime.operators.aggregate.window
org.apache.flink.table.runtime.operators.join.deltajoin
org.apache.flink.table.runtime.operators.over
org.apache.flink.table.runtime.operators.rank
org.apache.flink.table.runtime.operators.rank.async
org.apache.flink.table.runtime.operators.rank.window
org.apache.flink.table.runtime.operators.rank.window.combines
org.apache.flink.table.runtime.partitioner

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
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.

Methods in org.apache.flink.table.runtime.keyselector that return RowDataKeySelector

Modifier and Type	Method	Description
RowDataKeySelector	RowDataKeySelector.copy()

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

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

Constructor	Description
StreamingDeltaJoinOperatorFactory(AsyncDeltaJoinRunner rightLookupTableAsyncFunction, AsyncDeltaJoinRunner leftLookupTableAsyncFunction, RowDataKeySelector leftJoinKeySelector, RowDataKeySelector rightJoinKeySelector, long timeout, int capacity, org.apache.flink.table.types.logical.RowType leftStreamType, org.apache.flink.table.types.logical.RowType rightStreamType)

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, ZoneId shiftTimezone)

Uses of RowDataKeySelector in org.apache.flink.table.runtime.operators.join.deltajoin

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

Constructor

Description

StreamingDeltaJoinOperator(AsyncDeltaJoinRunner rightLookupTableAsyncFunction, AsyncDeltaJoinRunner leftLookupTableAsyncFunction, RowDataKeySelector leftJoinKeySelector, RowDataKeySelector rightJoinKeySelector, long timeout, int capacity, org.apache.flink.streaming.runtime.tasks.ProcessingTimeService processingTimeService, org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor, org.apache.flink.table.types.logical.RowType leftStreamType, org.apache.flink.table.types.logical.RowType rightStreamType)

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

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

Constructor

Description

NonTimeRangeUnboundedPrecedingFunction(long stateRetentionTime, GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, GeneratedRecordEqualiser genSortKeyEqualiser, GeneratedRecordComparator genSortKeyComparator, org.apache.flink.table.types.logical.LogicalType[] accTypes, org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes, org.apache.flink.table.types.logical.LogicalType[] sortKeyTypes, RowDataKeySelector sortKeySelector)

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
AbstractSyncStateTopNFunction(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)
AbstractTopNFunction(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)
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.async

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

Constructor	Description
AbstractAsyncStateTopNFunction(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)
AsyncStateAppendOnlyTopNFunction(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)
AsyncStateFastTop1Function(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)

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
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	Description
Factory(GeneratedRecordComparator genSortKeyComparator, RowDataKeySelector sortKeySelector, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> recordSerializer, long topN)

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

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

Constructor	Description
RowDataCustomStreamPartitioner(org.apache.flink.table.connector.source.abilities.SupportsLookupCustomShuffle.InputDataPartitioner partitioner, RowDataKeySelector keySelector)