This is an automated email from the ASF dual-hosted git repository.
hongze 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 b94c0fe579 [GLUTEN-10215][VL] Delta: Support update command in write
(#11271)
b94c0fe579 is described below
commit b94c0fe57913b4b6515e81a9a7892f5baf1af737
Author: Hongze Zhang <[email protected]>
AuthorDate: Tue Dec 16 16:18:46 2025 +0800
[GLUTEN-10215][VL] Delta: Support update command in write (#11271)
---
.../spark/sql/execution/datasources/v2/OffloadDeltaCommand.scala | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/backends-velox/src-delta33/main/scala/org/apache/spark/sql/execution/datasources/v2/OffloadDeltaCommand.scala
b/backends-velox/src-delta33/main/scala/org/apache/spark/sql/execution/datasources/v2/OffloadDeltaCommand.scala
index 4305165ad3..4f3e96585c 100644
---
a/backends-velox/src-delta33/main/scala/org/apache/spark/sql/execution/datasources/v2/OffloadDeltaCommand.scala
+++
b/backends-velox/src-delta33/main/scala/org/apache/spark/sql/execution/datasources/v2/OffloadDeltaCommand.scala
@@ -20,7 +20,7 @@ import org.apache.gluten.config.VeloxDeltaConfig
import org.apache.gluten.extension.columnar.offload.OffloadSingleNode
import org.apache.spark.sql.delta.catalog.DeltaCatalog
-import org.apache.spark.sql.delta.commands.DeleteCommand
+import org.apache.spark.sql.delta.commands.{DeleteCommand, UpdateCommand}
import org.apache.spark.sql.delta.sources.DeltaDataSource
import org.apache.spark.sql.execution.SparkPlan
import org.apache.spark.sql.execution.command.ExecutedCommandExec
@@ -32,6 +32,8 @@ case class OffloadDeltaCommand() extends OffloadSingleNode {
return plan
}
plan match {
+ case ExecutedCommandExec(uc: UpdateCommand) =>
+ ExecutedCommandExec(GlutenDeltaLeafRunnableCommand(uc))
case ExecutedCommandExec(dc: DeleteCommand) =>
ExecutedCommandExec(GlutenDeltaLeafRunnableCommand(dc))
case ExecutedCommandExec(s @ SaveIntoDataSourceCommand(_, _:
DeltaDataSource, _, _)) =>
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
