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 org.apache.flink.table.runtime.operators.join.SortMergeJoinFunction

getSortMergeJoinFunction(ClassLoader classLoader, ExecNodeConfig config, org.apache.flink.table.runtime.operators.join.FlinkJoinType joinType, org.apache.flink.table.types.logical.RowType leftType, org.apache.flink.table.types.logical.RowType rightType, int[] leftKeys, int[] rightKeys, org.apache.flink.table.types.logical.RowType keyType, boolean leftIsSmaller, boolean[] filterNulls, org.apache.flink.table.runtime.generated.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 org.apache.flink.table.runtime.operators.join.SortMergeJoinFunction getSortMergeJoinFunction(ClassLoader classLoader,
                                                                                                           ExecNodeConfig config,
                                                                                                           org.apache.flink.table.runtime.operators.join.FlinkJoinType joinType,
                                                                                                           org.apache.flink.table.types.logical.RowType leftType,
                                                                                                           org.apache.flink.table.types.logical.RowType rightType,
                                                                                                           int[] leftKeys,
                                                                                                           int[] rightKeys,
                                                                                                           org.apache.flink.table.types.logical.RowType keyType,
                                                                                                           boolean leftIsSmaller,
                                                                                                           boolean[] filterNulls,
                                                                                                           org.apache.flink.table.runtime.generated.GeneratedJoinCondition condFunc,
                                                                                                           double externalBufferMemRatio)