org.apache.flink.table.planner.plan.utils

Class SorMergeJoinOperatorUtil

java.lang.Object

org.apache.flink.table.planner.plan.utils.SorMergeJoinOperatorUtil

public class SorMergeJoinOperatorUtil
extends Object

Utility for SortMergeJoinOperator.

Method Summary

Modifier and Type	Method and Description
static SortMergeJoinFunction	getSortMergeJoinFunction(ClassLoader classLoader, ExecNodeConfig config, FlinkJoinType joinType, RowType leftType, RowType rightType, int[] leftKeys, int[] rightKeys, RowType keyType, boolean leftIsSmaller, boolean[] filterNulls, GeneratedJoinCondition condFunc, double externalBufferMemRatio)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getSortMergeJoinFunction

public static SortMergeJoinFunction getSortMergeJoinFunction(ClassLoader classLoader,
                                                             ExecNodeConfig config,
                                                             FlinkJoinType joinType,
                                                             RowType leftType,
                                                             RowType rightType,
                                                             int[] leftKeys,
                                                             int[] rightKeys,
                                                             RowType keyType,
                                                             boolean leftIsSmaller,
                                                             boolean[] filterNulls,
                                                             GeneratedJoinCondition condFunc,
                                                             double externalBufferMemRatio)