Constructor and Description |
---|
SortMergeJoinFunction(double externalBufferMemRatio,
FlinkJoinType type,
boolean leftIsSmaller,
GeneratedJoinCondition condFuncCode,
GeneratedProjection projectionCode1,
GeneratedProjection projectionCode2,
GeneratedNormalizedKeyComputer computer1,
GeneratedRecordComparator comparator1,
GeneratedNormalizedKeyComputer computer2,
GeneratedRecordComparator comparator2,
GeneratedRecordComparator genKeyComparator,
boolean[] filterNulls) |
Constructor and Description |
---|
RowDataEventComparator(GeneratedRecordComparator generatedComparator) |
Constructor and Description |
---|
BufferDataOverWindowOperator(OverWindowFrame[] overWindowFrames,
GeneratedRecordComparator genComparator,
boolean isRowAllInFixedPart) |
NonBufferOverWindowOperator(GeneratedAggsHandleFunction[] aggsHandlers,
GeneratedRecordComparator genComparator,
boolean[] resetAccumulators) |
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) |
Modifier and Type | Method and Description |
---|---|
GeneratedRecordComparator |
ComparableRecordComparator.getGeneratedRecordComparator() |
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) |
ComparableRecordComparator(GeneratedRecordComparator generatedRecordComparator,
int[] compareKeyPositions,
LogicalType[] compareKeyTypes,
boolean[] compareOrders,
boolean[] nullsIsLast) |
FastTop1Function(StateTtlConfig ttlConfig,
InternalTypeInfo<RowData> inputRowType,
GeneratedRecordComparator generatedSortKeyComparator,
RowDataKeySelector sortKeySelector,
RankType rankType,
RankRange rankRange,
boolean generateUpdateBefore,
boolean outputRankNumber,
long cacheSize) |
UpdatableTopNFunction(StateTtlConfig ttlConfig,
InternalTypeInfo<RowData> inputRowType,
RowDataKeySelector rowKeySelector,
GeneratedRecordComparator generatedRecordComparator,
RowDataKeySelector sortKeySelector,
RankType rankType,
RankRange rankRange,
boolean generateUpdateBefore,
boolean outputRankNumber,
long cacheSize) |
Modifier and Type | Method and Description |
---|---|
WindowRankOperatorBuilder |
WindowRankOperatorBuilder.sortKeyComparator(GeneratedRecordComparator genSortKeyComparator) |
Constructor and Description |
---|
Factory(GeneratedRecordComparator genSortKeyComparator,
RowDataKeySelector sortKeySelector,
TypeSerializer<RowData> recordSerializer,
long topN) |
Constructor and Description |
---|
WindowRankProcessor(TypeSerializer<RowData> inputSerializer,
GeneratedRecordComparator genSortKeyComparator,
TypeSerializer<RowData> sortKeySerializer,
WindowBuffer.Factory bufferFactory,
long rankStart,
long rankEnd,
boolean outputRankNumber,
int windowEndIndex,
java.time.ZoneId shiftTimeZone) |
Constructor and Description |
---|
ProcTimeSortOperator(InternalTypeInfo<RowData> inputRowType,
GeneratedRecordComparator gComparator) |
RankOperator(GeneratedRecordComparator partitionByGenComp,
GeneratedRecordComparator orderByGenComp,
long rankStart,
long rankEnd,
boolean outputRankFunColumn) |
RowTimeSortOperator(InternalTypeInfo<RowData> inputRowType,
int rowTimeIdx,
GeneratedRecordComparator gComparator) |
SortLimitOperator(boolean isGlobal,
long limitStart,
long limitEnd,
GeneratedRecordComparator genComparator) |
SortOperator(GeneratedNormalizedKeyComputer gComputer,
GeneratedRecordComparator gComparator) |
StreamSortOperator(InternalTypeInfo<RowData> inputRowType,
GeneratedRecordComparator gComparator) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.