Constructor and Description |
---|
SortMergeJoinOperator(long reservedSortMemory,
long externalBufferMemory,
FlinkJoinType type,
boolean leftIsSmaller,
GeneratedJoinCondition condFuncCode,
GeneratedProjection projectionCode1,
GeneratedProjection projectionCode2,
GeneratedNormalizedKeyComputer computer1,
GeneratedRecordComparator comparator1,
GeneratedNormalizedKeyComputer computer2,
GeneratedRecordComparator comparator2,
GeneratedRecordComparator genKeyComparator,
boolean[] filterNulls) |
SortMergeJoinOperator(long reservedSortMemory1,
long reservedSortMemory2,
long externalBufferMemory,
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 |
---|
BaseRowEventComparator(GeneratedRecordComparator generatedComparator) |
Constructor and Description |
---|
BufferDataOverWindowOperator(long memorySize,
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) |
Constructor and Description |
---|
AppendOnlyTopNFunction(long minRetentionTime,
long maxRetentionTime,
BaseRowTypeInfo inputRowType,
GeneratedRecordComparator sortKeyGeneratedRecordComparator,
BaseRowKeySelector sortKeySelector,
RankType rankType,
RankRange rankRange,
boolean generateRetraction,
boolean outputRankNumber,
long cacheSize) |
RetractableTopNFunction(long minRetentionTime,
long maxRetentionTime,
BaseRowTypeInfo inputRowType,
GeneratedRecordComparator generatedRecordComparator,
BaseRowKeySelector sortKeySelector,
RankType rankType,
RankRange rankRange,
GeneratedRecordEqualiser generatedEqualiser,
boolean generateRetraction,
boolean outputRankNumber) |
UpdatableTopNFunction(long minRetentionTime,
long maxRetentionTime,
BaseRowTypeInfo inputRowType,
BaseRowKeySelector rowKeySelector,
GeneratedRecordComparator generatedRecordComparator,
BaseRowKeySelector sortKeySelector,
RankType rankType,
RankRange rankRange,
boolean generateRetraction,
boolean outputRankNumber,
long cacheSize) |
Constructor and Description |
---|
ProcTimeSortOperator(BaseRowTypeInfo inputRowType,
GeneratedRecordComparator gComparator) |
RankOperator(GeneratedRecordComparator partitionByGenComp,
GeneratedRecordComparator orderByGenComp,
long rankStart,
long rankEnd,
boolean outputRankFunColumn) |
RowTimeSortOperator(BaseRowTypeInfo inputRowType,
int rowTimeIdx,
GeneratedRecordComparator gComparator) |
SortLimitOperator(boolean isGlobal,
long limitStart,
long limitEnd,
GeneratedRecordComparator genComparator) |
SortOperator(long reservedMemorySize,
GeneratedNormalizedKeyComputer gComputer,
GeneratedRecordComparator gComparator) |
StreamSortOperator(BaseRowTypeInfo inputRowType,
GeneratedRecordComparator gComparator) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.