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

Class SetOpRewriteUtil

java.lang.Object

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

public class SetOpRewriteUtil
extends Object

Util class that rewrite SetOp.

Constructor Summary

Constructors

Constructor	Description
SetOpRewriteUtil()

Method Summary

Modifier and Type	Method	Description
static List<org.apache.calcite.rex.RexNode>	generateEqualsCondition(RelBuilder relBuilder, org.apache.calcite.rel.RelNode left, org.apache.calcite.rel.RelNode right, List<Integer> keys)	Generate equals condition by keys (The index on both sides is the same) to join left relNode and right relNode.
static org.apache.calcite.rel.RelNode	replicateRows(RelBuilder relBuilder, org.apache.calcite.rel.type.RelDataType outputRelDataType, List<Integer> fields)	Use table function to replicate the row N times.

Methods inherited from class java.lang.Object

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

Constructor Detail

SetOpRewriteUtil

public SetOpRewriteUtil()

Method Detail

generateEqualsCondition

public static List<org.apache.calcite.rex.RexNode> generateEqualsCondition(RelBuilder relBuilder,
                                                                           org.apache.calcite.rel.RelNode left,
                                                                           org.apache.calcite.rel.RelNode right,
                                                                           List<Integer> keys)

Generate equals condition by keys (The index on both sides is the same) to join left relNode and right relNode.

replicateRows

public static org.apache.calcite.rel.RelNode replicateRows(RelBuilder relBuilder,
                                                           org.apache.calcite.rel.type.RelDataType outputRelDataType,
                                                           List<Integer> fields)

Use table function to replicate the row N times. First field is long type, and the rest are the row fields.