Uses of Class
org.apache.flink.table.runtime.generated.GeneratedRecordComparator
-
-
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 Description SortMergeJoinFunction(double externalBufferMemRatio, FlinkJoinType type, boolean leftIsSmaller, int maxNumFileHandles, boolean compressionEnabled, int compressionBlockSize, boolean asyncMergeEnabled, 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 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 Description BufferDataOverWindowOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters, OverWindowFrame[] overWindowFrames, GeneratedRecordComparator genComparator, boolean isRowAllInFixedPart)BufferDataOverWindowOperator(OverWindowFrame[] overWindowFrames, GeneratedRecordComparator genComparator, boolean isRowAllInFixedPart)NonBufferOverWindowOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters, GeneratedAggsHandleFunction[] aggsHandlers, GeneratedRecordComparator genComparator, boolean[] resetAccumulators)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 Description RangeSlidingOverFrame(org.apache.flink.table.types.logical.RowType inputType, org.apache.flink.table.types.logical.RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator lboundComparator, GeneratedRecordComparator rboundComparator)RangeUnboundedFollowingOverFrame(org.apache.flink.table.types.logical.RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator boundComparator)RangeUnboundedPrecedingOverFrame(GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator boundComparator) -
Uses of GeneratedRecordComparator in org.apache.flink.table.runtime.operators.rank
Methods in org.apache.flink.table.runtime.operators.rank that return GeneratedRecordComparator Modifier and Type Method Description GeneratedRecordComparatorComparableRecordComparator. getGeneratedRecordComparator()Constructors in org.apache.flink.table.runtime.operators.rank with parameters of type GeneratedRecordComparator 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)ComparableRecordComparator(GeneratedRecordComparator generatedRecordComparator, int[] compareKeyPositions, org.apache.flink.table.types.logical.LogicalType[] compareKeyTypes, boolean[] compareOrders, boolean[] nullsIsLast)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)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 GeneratedRecordComparator in org.apache.flink.table.runtime.operators.rank.async
Constructors in org.apache.flink.table.runtime.operators.rank.async with parameters of type GeneratedRecordComparator 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 GeneratedRecordComparator in org.apache.flink.table.runtime.operators.rank.window
Methods in org.apache.flink.table.runtime.operators.rank.window with parameters of type GeneratedRecordComparator Modifier and Type Method Description WindowRankOperatorBuilderWindowRankOperatorBuilder. sortKeyComparator(GeneratedRecordComparator genSortKeyComparator) -
Uses of GeneratedRecordComparator 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 GeneratedRecordComparator 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 GeneratedRecordComparator in org.apache.flink.table.runtime.operators.rank.window.processors
Constructors in org.apache.flink.table.runtime.operators.rank.window.processors with parameters of type GeneratedRecordComparator Constructor Description SyncStateWindowRankProcessor(org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> inputSerializer, GeneratedRecordComparator genSortKeyComparator, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> sortKeySerializer, WindowBuffer.Factory bufferFactory, long rankStart, long rankEnd, boolean outputRankNumber, int windowEndIndex, ZoneId shiftTimeZone) -
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 Description ProcTimeSortOperator(InternalTypeInfo<org.apache.flink.table.data.RowData> inputRowType, GeneratedRecordComparator gComparator)RankOperator(GeneratedRecordComparator partitionByGenComp, GeneratedRecordComparator orderByGenComp, long rankStart, long rankEnd, boolean outputRankFunColumn)RowTimeSortOperator(InternalTypeInfo<org.apache.flink.table.data.RowData> inputRowType, int rowTimeIdx, GeneratedRecordComparator gComparator)SortLimitOperator(boolean isGlobal, long limitStart, long limitEnd, GeneratedRecordComparator genComparator)SortOperator(GeneratedNormalizedKeyComputer gComputer, GeneratedRecordComparator gComparator, int maxNumFileHandles, boolean compressionEnabled, int compressionBlockSize, boolean asyncMergeEnabled)StreamSortOperator(InternalTypeInfo<org.apache.flink.table.data.RowData> inputRowType, GeneratedRecordComparator gComparator)
-