This is an automated email from the ASF dual-hosted git repository.
wangzhen pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git
The following commit(s) were added to refs/heads/main by this push:
new bf38aee04b [GLUTEN-11048][VL] Implement
OrderPreservingNode/PartitioningPreservingNode for ColumnarPartialProjectExec
(#11049)
bf38aee04b is described below
commit bf38aee04ba50af2b83e209743eade3c239df39e
Author: Zhen Wang <[email protected]>
AuthorDate: Tue Nov 11 10:06:07 2025 +0800
[GLUTEN-11048][VL] Implement OrderPreservingNode/PartitioningPreservingNode
for ColumnarPartialProjectExec (#11049)
---
.../org/apache/gluten/execution/ColumnarPartialProjectExec.scala | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git
a/backends-velox/src/main/scala/org/apache/gluten/execution/ColumnarPartialProjectExec.scala
b/backends-velox/src/main/scala/org/apache/gluten/execution/ColumnarPartialProjectExec.scala
index 144f865ade..40865a0dd4 100644
---
a/backends-velox/src/main/scala/org/apache/gluten/execution/ColumnarPartialProjectExec.scala
+++
b/backends-velox/src/main/scala/org/apache/gluten/execution/ColumnarPartialProjectExec.scala
@@ -30,7 +30,7 @@ import org.apache.spark.rdd.RDD
import org.apache.spark.sql.catalyst.InternalRow
import org.apache.spark.sql.catalyst.expressions._
import org.apache.spark.sql.catalyst.plans.QueryPlan
-import org.apache.spark.sql.execution.{ExplainUtils, ProjectExec, SparkPlan,
UnaryExecNode}
+import org.apache.spark.sql.execution.{ExplainUtils, OrderPreservingNodeShim,
PartitioningPreservingNodeShim, ProjectExec, SparkPlan, UnaryExecNode}
import org.apache.spark.sql.execution.metric.{SQLMetric, SQLMetrics}
import org.apache.spark.sql.hive.{HiveUDFTransformer, VeloxHiveUDFTransformer}
import org.apache.spark.sql.vectorized.{ColumnarBatch, ColumnVector}
@@ -53,6 +53,8 @@ import scala.collection.mutable.ListBuffer
case class ColumnarPartialProjectExec(projectList: Seq[NamedExpression],
child: SparkPlan)(
replacedAlias: Seq[Alias])
extends UnaryExecNode
+ with OrderPreservingNodeShim
+ with PartitioningPreservingNodeShim
with ValidatablePlan {
private val projectAttributes: ListBuffer[Attribute] = ListBuffer()
@@ -275,6 +277,10 @@ case class ColumnarPartialProjectExec(projectList:
Seq[NamedExpression], child:
override protected def withNewChildInternal(newChild: SparkPlan):
ColumnarPartialProjectExec = {
copy(child = newChild)(replacedAlias)
}
+
+ override protected def orderingExpressions: Seq[SortOrder] =
child.outputOrdering
+
+ override protected def outputExpressions: Seq[NamedExpression] =
child.output ++ replacedAlias
}
object ColumnarPartialProjectExec {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
