This is an automated email from the ASF dual-hosted git repository.
richox pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/auron.git
The following commit(s) were added to refs/heads/master by this push:
new 02cde127 [AURON #1665] Override verboseStringWithOperatorId in
NativeFileSourceScanBase (#1643)
02cde127 is described below
commit 02cde12717413f43cb090f1553c0f688fbbb1104
Author: Thomas <[email protected]>
AuthorDate: Mon Dec 1 14:30:14 2025 +0800
[AURON #1665] Override verboseStringWithOperatorId in
NativeFileSourceScanBase (#1643)
* [AURON #1642] Align NativeFileSourceScanBase.verboseStringWithOperatorId
with vanilla Spark
* [AURON #1665] Override verboseStringWithOperatorId in
NativeFileSourceScanBase
* add comment
* fix code style
* up
* fix code style
---
.../spark/sql/execution/auron/plan/NativeFileSourceScanBase.scala | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git
a/spark-extension/src/main/scala/org/apache/spark/sql/execution/auron/plan/NativeFileSourceScanBase.scala
b/spark-extension/src/main/scala/org/apache/spark/sql/execution/auron/plan/NativeFileSourceScanBase.scala
index ad633a86..5f26d921 100644
---
a/spark-extension/src/main/scala/org/apache/spark/sql/execution/auron/plan/NativeFileSourceScanBase.scala
+++
b/spark-extension/src/main/scala/org/apache/spark/sql/execution/auron/plan/NativeFileSourceScanBase.scala
@@ -32,9 +32,7 @@ import org.apache.spark.sql.auron.Shims
import org.apache.spark.sql.catalyst.expressions.Attribute
import org.apache.spark.sql.catalyst.expressions.Literal
import org.apache.spark.sql.catalyst.plans.physical.Partitioning
-import org.apache.spark.sql.execution.FileSourceScanExec
-import org.apache.spark.sql.execution.LeafExecNode
-import org.apache.spark.sql.execution.SparkPlan
+import org.apache.spark.sql.execution.{FileSourceScanExec, LeafExecNode,
SparkPlan}
import org.apache.spark.sql.execution.datasources.FilePartition
import org.apache.spark.sql.execution.datasources.FileScanRDD
import org.apache.spark.sql.execution.datasources.PartitionedFile
@@ -154,4 +152,8 @@ abstract class NativeFileSourceScanBase(basedFileScan:
FileSourceScanExec)
}
override protected def doCanonicalize(): SparkPlan =
basedFileScan.canonicalized
+
+ override def verboseStringWithOperatorId(): String = {
+ basedFileScan.verboseStringWithOperatorId()
+ }
}