update veloxSparkPlanExecApi

apache · Sep 19, 2024 · 4303560 · 4303560
1 parent fda681d
commit 4303560
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 3 deletions.
diff --git a/...ickhouse/src/main/scala/org/apache/gluten/backendsapi/clickhouse/CHSparkPlanExecApi.scala b/...ickhouse/src/main/scala/org/apache/gluten/backendsapi/clickhouse/CHSparkPlanExecApi.scala
@@ -77,7 +77,7 @@ class CHSparkPlanExecApi extends SparkPlanExecApi with Logging {
 
   override def genProjectExecTransformer(
       projectList: Seq[NamedExpression],
-      child: SparkPlan): ProjectExecTransformer = {
+      child: SparkPlan): ProjectExecTransformerBase = {
     def processProjectExecTransformer(projectList: Seq[NamedExpression]): Seq[NamedExpression] = {
       // When there is a MergeScalarSubqueries which will create the named_struct with the
       // same name, looks like {'bloomFilter', BF1, 'bloomFilter', BF2}

diff --git a/...ends-velox/src/main/scala/org/apache/gluten/backendsapi/velox/VeloxSparkPlanExecApi.scala b/...ends-velox/src/main/scala/org/apache/gluten/backendsapi/velox/VeloxSparkPlanExecApi.scala
@@ -295,6 +295,12 @@ class VeloxSparkPlanExecApi extends SparkPlanExecApi {
     FilterExecTransformer(condition, child)
   }
 
+  override def genProjectExecTransformer(
+      projectList: Seq[NamedExpression],
+      child: SparkPlan): ProjectExecTransformerBase = {
+    ProjectExecTransformer(projectList, child)
+  }
+
   /** Generate HashAggregateExecTransformer. */
   override def genHashAggregateExecTransformer(
       requiredChildDistributionExpressions: Option[Seq[Expression]],

diff --git a/gluten-substrait/src/main/scala/org/apache/gluten/backendsapi/SparkPlanExecApi.scala b/gluten-substrait/src/main/scala/org/apache/gluten/backendsapi/SparkPlanExecApi.scala
@@ -69,8 +69,7 @@ trait SparkPlanExecApi {
 
   def genProjectExecTransformer(
       projectList: Seq[NamedExpression],
-      child: SparkPlan): ProjectExecTransformer =
-    ProjectExecTransformer.createUnsafe(projectList, child)
+      child: SparkPlan): ProjectExecTransformerBase
 
   /** Generate HashAggregateExecTransformer. */
   def genHashAggregateExecTransformer(