diff --git a/spark/spark-3.5/src/main/scala/org/apache/sedona/sql/datasources/geopackage/GeoPackagePartitionReader.scala b/spark/spark-3.5/src/main/scala/org/apache/sedona/sql/datasources/geopackage/GeoPackagePartitionReader.scala index 9d328a10ea..4e59163922 100644 --- a/spark/spark-3.5/src/main/scala/org/apache/sedona/sql/datasources/geopackage/GeoPackagePartitionReader.scala +++ b/spark/spark-3.5/src/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/spark/spark-3.5/src/main/scala/org/apache/sedona/sql/datasources/geopackage/GeoPackagePartitionReaderFactory.scala b/spark/spark-3.5/src/main/scala/org/apache/sedona/sql/datasources/geopackage/GeoPackagePartitionReaderFactory.scala index e8ca44511a..b1d38996b0 100644 --- a/spark/spark-3.5/src/main/scala/org/apache/sedona/sql/datasources/geopackage/GeoPackagePartitionReaderFactory.scala +++ b/spark/spark-3.5/src/main/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 {