delete AliasAwareOutputExpression

apache · Oct 18, 2023 · 9f1f793 · 9f1f793
1 parent 8a0d44e
commit 9f1f793
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 32 deletions.
diff --git a/gluten-core/src/main/scala/io/glutenproject/execution/BasicPhysicalOperatorTransformer.scala b/gluten-core/src/main/scala/io/glutenproject/execution/BasicPhysicalOperatorTransformer.scala
@@ -48,7 +48,6 @@ abstract class FilterExecTransformerBase(val cond: Expression, val input: SparkP
   extends UnaryExecNode
   with TransformSupport
   with PredicateHelper
-  with AliasAwareOutputPartitioning
   with Logging {
 
   // Note: "metrics" is made transient to avoid sending driver-side metrics to tasks.
@@ -130,8 +129,6 @@ abstract class FilterExecTransformerBase(val cond: Expression, val input: SparkP
     }
   }
 
-  override protected def outputExpressions: Seq[NamedExpression] = output
-
   override def output: Seq[Attribute] = {
     child.output.map {
       a =>
@@ -220,7 +217,6 @@ case class ProjectExecTransformer private (projectList: Seq[NamedExpression], ch
   extends UnaryExecNode
   with TransformSupport
   with PredicateHelper
-  with AliasAwareOutputPartitioning
   with Logging {
 
   // Note: "metrics" is made transient to avoid sending driver-side metrics to tasks.
@@ -358,9 +354,7 @@ case class ProjectExecTransformer private (projectList: Seq[NamedExpression], ch
   override def doExecuteColumnar(): RDD[ColumnarBatch] = {
     throw new UnsupportedOperationException(s"This operator doesn't support doExecuteColumnar().")
   }
-
-  override protected def outputExpressions: Seq[NamedExpression] = projectList
-
+
   override protected def doExecute()
       : org.apache.spark.rdd.RDD[org.apache.spark.sql.catalyst.InternalRow] = {
     throw new UnsupportedOperationException(s"This operator doesn't support doExecute().")

diff --git a/shims/spark34/src/main/scala/org/apache/spark/sql/execution/AliasAwareOutputExpression.scala b/shims/spark34/src/main/scala/org/apache/spark/sql/execution/AliasAwareOutputExpression.scala