[FLINK-20515][table-planner-blink] Remove MultipleInputRel

This closes apache#14380
burkaygur · Dec 15, 2020 · 5088b8a · 5088b8a
1 parent 6c886a4
commit 5088b8a
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 78 deletions.
diff --git a/...nk/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUniqueKeys.scala b/...nk/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUniqueKeys.scala
@@ -25,7 +25,6 @@ import org.apache.flink.table.planner.calcite.FlinkTypeFactory
 import org.apache.flink.table.planner.plan.nodes.calcite.{Expand, Rank, WatermarkAssigner, WindowAggregate}
 import org.apache.flink.table.planner.plan.nodes.common.CommonLookupJoin
 import org.apache.flink.table.planner.plan.nodes.logical._
-import org.apache.flink.table.planner.plan.nodes.physical.MultipleInputRel
 import org.apache.flink.table.planner.plan.nodes.physical.batch._
 import org.apache.flink.table.planner.plan.nodes.physical.stream._
 import org.apache.flink.table.planner.plan.schema.{FlinkPreparingTableBase, TableSourceTable}
@@ -43,8 +42,8 @@ import org.apache.calcite.rel.core._
 import org.apache.calcite.rel.metadata._
 import org.apache.calcite.rel.{RelNode, SingleRel}
 import org.apache.calcite.rex.{RexCall, RexInputRef, RexNode}
+import org.apache.calcite.sql.SqlKind
 import org.apache.calcite.sql.fun.SqlStdOperatorTable
-import org.apache.calcite.sql.{SqlKind, SqlWindowTableFunction}
 import org.apache.calcite.util.{Bug, BuiltInMethod, ImmutableBitSet, Util}
 
 import java.util
@@ -592,12 +591,6 @@ class FlinkRelMdUniqueKeys private extends MetadataHandler[BuiltInMetadata.Uniqu
     }
   }
 
-  def getUniqueKeys(
-      multipleInput: MultipleInputRel,
-      mq: RelMetadataQuery,
-      ignoreNulls: Boolean): JSet[ImmutableBitSet] =
-    mq.getUniqueKeys(multipleInput.outputRel, ignoreNulls)
-
   def getUniqueKeys(
       subset: RelSubset,
       mq: RelMetadataQuery,

diff --git a/.../src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/MultipleInputRel.scala b/.../src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/MultipleInputRel.scala