public class SortMergeJoinFunction extends Object implements Serializable
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) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
endInput(int inputId) |
void |
open(boolean adaptiveHashJoin,
StreamTask<?,?> taskContainer,
StreamConfig operatorConfig,
StreamRecordCollector collector,
long totalMemory,
RuntimeContext runtimeContext,
OperatorMetricGroup operatorMetricGroup) |
void |
processElement1(RowData element) |
void |
processElement2(RowData element) |
public 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)
public void open(boolean adaptiveHashJoin, StreamTask<?,?> taskContainer, StreamConfig operatorConfig, StreamRecordCollector collector, long totalMemory, RuntimeContext runtimeContext, OperatorMetricGroup operatorMetricGroup) throws Exception
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.