Uses of Class
org.apache.flink.table.runtime.generated.GeneratedRecordComparator

Packages that use GeneratedRecordComparator

Package	Description
org.apache.flink.table.runtime.operators.join
org.apache.flink.table.runtime.operators.match
org.apache.flink.table.runtime.operators.over
org.apache.flink.table.runtime.operators.over.frame
org.apache.flink.table.runtime.operators.rank
org.apache.flink.table.runtime.operators.sort

Uses of GeneratedRecordComparator in org.apache.flink.table.runtime.operators.join

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

Constructor and Description

SortMergeJoinOperator(double externalBufferMemRatio, FlinkJoinType type, boolean leftIsSmaller, GeneratedJoinCondition condFuncCode, GeneratedProjection projectionCode1, GeneratedProjection projectionCode2, GeneratedNormalizedKeyComputer computer1, GeneratedRecordComparator comparator1, GeneratedNormalizedKeyComputer computer2, GeneratedRecordComparator comparator2, GeneratedRecordComparator genKeyComparator, boolean[] filterNulls)

Uses of GeneratedRecordComparator in org.apache.flink.table.runtime.operators.match

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

Constructor and Description
RowDataEventComparator(GeneratedRecordComparator generatedComparator)

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

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

Constructor and Description
BufferDataOverWindowOperator(OverWindowFrame[] overWindowFrames, GeneratedRecordComparator genComparator, boolean isRowAllInFixedPart)
NonBufferOverWindowOperator(GeneratedAggsHandleFunction[] aggsHandlers, GeneratedRecordComparator genComparator, boolean[] resetAccumulators)

Uses of GeneratedRecordComparator in org.apache.flink.table.runtime.operators.over.frame

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

Constructor and Description
RangeSlidingOverFrame(RowType inputType, RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator lboundComparator, GeneratedRecordComparator rboundComparator)
RangeUnboundedFollowingOverFrame(RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator boundComparator)
RangeUnboundedPrecedingOverFrame(GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator boundComparator)

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

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

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

Uses of GeneratedRecordComparator in org.apache.flink.table.runtime.operators.sort

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

Constructor and Description
ProcTimeSortOperator(RowDataTypeInfo inputRowType, GeneratedRecordComparator gComparator)
RankOperator(GeneratedRecordComparator partitionByGenComp, GeneratedRecordComparator orderByGenComp, long rankStart, long rankEnd, boolean outputRankFunColumn)
RowTimeSortOperator(RowDataTypeInfo inputRowType, int rowTimeIdx, GeneratedRecordComparator gComparator)
SortLimitOperator(boolean isGlobal, long limitStart, long limitEnd, GeneratedRecordComparator genComparator)
SortOperator(GeneratedNormalizedKeyComputer gComputer, GeneratedRecordComparator gComparator)
StreamSortOperator(RowDataTypeInfo inputRowType, GeneratedRecordComparator gComparator)