[GLUTEN-6834][CORE] Remove unused DDL plan that doesn't correspond to…

… Substrait spec (#6833)
apache · Aug 15, 2024 · 9fb9899 · 9fb9899
1 parent 5897d34
commit 9fb9899
Show file tree

Hide file tree

Showing 8 changed files with 0 additions and 262 deletions.
diff --git a/gluten-core/src/main/java/org/apache/gluten/substrait/ddlplan/DllNode.java b/gluten-core/src/main/java/org/apache/gluten/substrait/ddlplan/DllNode.java
diff --git a/gluten-core/src/main/java/org/apache/gluten/substrait/ddlplan/DllPlanNode.java b/gluten-core/src/main/java/org/apache/gluten/substrait/ddlplan/DllPlanNode.java
diff --git a/gluten-core/src/main/java/org/apache/gluten/substrait/ddlplan/DllTransformContext.scala b/gluten-core/src/main/java/org/apache/gluten/substrait/ddlplan/DllTransformContext.scala
diff --git a/gluten-core/src/main/java/org/apache/gluten/substrait/ddlplan/InsertOutputBuilder.java b/gluten-core/src/main/java/org/apache/gluten/substrait/ddlplan/InsertOutputBuilder.java
diff --git a/gluten-core/src/main/java/org/apache/gluten/substrait/ddlplan/InsertOutputNode.java b/gluten-core/src/main/java/org/apache/gluten/substrait/ddlplan/InsertOutputNode.java
diff --git a/gluten-core/src/main/java/org/apache/gluten/substrait/ddlplan/InsertPlanNode.java b/gluten-core/src/main/java/org/apache/gluten/substrait/ddlplan/InsertPlanNode.java
diff --git a/gluten-core/src/main/resources/substrait/proto/substrait/ddl.proto b/gluten-core/src/main/resources/substrait/proto/substrait/ddl.proto
diff --git a/gluten-core/src/main/scala/org/apache/gluten/substrait/SubstraitContext.scala b/gluten-core/src/main/scala/org/apache/gluten/substrait/SubstraitContext.scala
@@ -16,8 +16,6 @@
  */
 package org.apache.gluten.substrait
 
-import org.apache.gluten.substrait.ddlplan.InsertOutputNode
-
 import java.lang.{Long => JLong}
 import java.security.InvalidParameterException
 import java.util.{ArrayList => JArrayList, HashMap => JHashMap, List => JList, Map => JMap}
@@ -64,16 +62,9 @@ class SubstraitContext extends Serializable {
   private val aggregationParamsMap = new JHashMap[JLong, AggregationParams]()
 
   private var iteratorIndex: JLong = 0L
-  private var insertOutputNode: InsertOutputNode = _
   private var operatorId: JLong = 0L
   private var relId: JLong = 0L
 
-  def getInsertOutputNode: InsertOutputNode = insertOutputNode
-
-  def setInsertOutputNode(insertOutputNode: InsertOutputNode): Unit = {
-    this.insertOutputNode = insertOutputNode
-  }
-
   def registerFunction(funcName: String): JLong = {
     if (!functionMap.containsKey(funcName)) {
       val newFunctionId: JLong = functionMap.size.toLong