Fix tests for spark 3.5 and 3.4.

apache · Oct 12, 2024 · fc24a6e · fc24a6e
1 parent 18186b9
commit fc24a6e
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 11 deletions.
diff --git a/...c/main/scala/org/apache/sedona/sql/datasources/geopackage/GeoPackagePartitionReader.scala b/...c/main/scala/org/apache/sedona/sql/datasources/geopackage/GeoPackagePartitionReader.scala
@@ -32,12 +32,12 @@ import java.io.File
 import java.sql.ResultSet
 
 case class GeoPackagePartitionReader(
-                                      var rs: ResultSet,
-                                      options: GeoPackageReadOptions,
-                                      broadcastedConf: Broadcast[SerializableConfiguration],
-                                      var currentTempFile: File,
-                                      copying: Boolean = false)
-  extends PartitionReader[InternalRow] {
+    var rs: ResultSet,
+    options: GeoPackageReadOptions,
+    broadcastedConf: Broadcast[SerializableConfiguration],
+    var currentTempFile: File,
+    copying: Boolean = false)
+    extends PartitionReader[InternalRow] {
 
   private var values: Seq[Any] = Seq.empty
   private var currentFile = options.currentFile

diff --git a/...scala/org/apache/sedona/sql/datasources/geopackage/GeoPackagePartitionReaderFactory.scala b/...scala/org/apache/sedona/sql/datasources/geopackage/GeoPackagePartitionReaderFactory.scala
@@ -31,11 +31,11 @@ import org.apache.spark.sql.types.StructType
 import org.apache.spark.util.SerializableConfiguration
 
 case class GeoPackagePartitionReaderFactory(
-                                             sparkSession: SparkSession,
-                                             broadcastedConf: Broadcast[SerializableConfiguration],
-                                             loadOptions: GeoPackageOptions,
-                                             dataSchema: StructType)
-  extends PartitionReaderFactory {
+    sparkSession: SparkSession,
+    broadcastedConf: Broadcast[SerializableConfiguration],
+    loadOptions: GeoPackageOptions,
+    dataSchema: StructType)
+    extends PartitionReaderFactory {
 
   override def createReader(partition: InputPartition): PartitionReader[InternalRow] = {
     val partitionFiles = partition match {