fix compile errors

apache · Mar 10, 2025 · 50f2c0f · 50f2c0f
1 parent e809800
commit 50f2c0f
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/shims/spark32/src/main/scala/org/apache/gluten/sql/shims/spark32/Spark32Shims.scala b/shims/spark32/src/main/scala/org/apache/gluten/sql/shims/spark32/Spark32Shims.scala
@@ -197,7 +197,7 @@ class Spark32Shims extends SparkShims {
   override def supportDuplicateReadingTracking: Boolean = false
 
   def getFileStatus(partition: PartitionDirectory): Seq[(FileStatus, Map[String, Any])] =
-    partition.files.map(f => (f, Map.empty))
+    partition.files.map(f => (f, Map.empty[String, Any]))
 
   def isFileSplittable(
       relation: HadoopFsRelation,
@@ -215,7 +215,7 @@ class Spark32Shims extends SparkShims {
       isSplitable: Boolean,
       maxSplitBytes: Long,
       partitionValues: InternalRow,
-      metadata: Map[String, Any] = Map.empty): Seq[PartitionedFile]
+      metadata: Map[String, Any] = Map.empty): Seq[PartitionedFile] = {
     PartitionedFileUtil.splitFiles(
       sparkSession,
       file,

diff --git a/shims/spark33/src/main/scala/org/apache/gluten/sql/shims/spark33/Spark33Shims.scala b/shims/spark33/src/main/scala/org/apache/gluten/sql/shims/spark33/Spark33Shims.scala
@@ -289,7 +289,7 @@ class Spark33Shims extends SparkShims {
   override def supportDuplicateReadingTracking: Boolean = true
 
   def getFileStatus(partition: PartitionDirectory): Seq[(FileStatus, Map[String, Any])] =
-    partition.files.map(f => (f, Map.empty))
+    partition.files.map(f => (f, Map.empty[String, Any]))
 
   def isFileSplittable(
       relation: HadoopFsRelation,
@@ -307,7 +307,7 @@ class Spark33Shims extends SparkShims {
       isSplitable: Boolean,
       maxSplitBytes: Long,
       partitionValues: InternalRow,
-      metadata: Map[String, Any] = Map.empty): Seq[PartitionedFile]
+      metadata: Map[String, Any] = Map.empty): Seq[PartitionedFile] = {
     PartitionedFileUtil.splitFiles(
       sparkSession,
       file,

diff --git a/shims/spark34/src/main/scala/org/apache/gluten/sql/shims/spark34/Spark34Shims.scala b/shims/spark34/src/main/scala/org/apache/gluten/sql/shims/spark34/Spark34Shims.scala
@@ -346,7 +346,7 @@ class Spark34Shims extends SparkShims {
   override def supportDuplicateReadingTracking: Boolean = true
 
   def getFileStatus(partition: PartitionDirectory): Seq[(FileStatus, Map[String, Any])] =
-    partition.files.map(f => (f, Map.empty))
+    partition.files.map(f => (f, Map.empty[String, Any]))
 
   def isFileSplittable(
       relation: HadoopFsRelation,
@@ -386,7 +386,7 @@ class Spark34Shims extends SparkShims {
       isSplitable: Boolean,
       maxSplitBytes: Long,
       partitionValues: InternalRow,
-      metadata: Map[String, Any] = Map.empty): Seq[PartitionedFile]
+      metadata: Map[String, Any] = Map.empty): Seq[PartitionedFile] = {
     PartitionedFileUtil.splitFiles(
       sparkSession,
       file,