Add other missing data types.

apache · Sep 30, 2024 · fd05d11 · fd05d11
1 parent b7bd219
commit fd05d11
Showing 1 changed file with 1 addition and 21 deletions.
diff --git a/...org/apache/sedona/sql/datasources/geopackage/connection/GeoPackageConnectionManager.scala b/...org/apache/sedona/sql/datasources/geopackage/connection/GeoPackageConnectionManager.scala
@@ -18,14 +18,9 @@
  */
 package org.apache.sedona.sql.datasources.geopackage.connection
 
-import org.apache.hadoop.conf.Configuration
-import org.apache.hadoop.fs.Path
-import org.apache.sedona.sql.datasources.geopackage.model.{GeoPackageField, PartitionOptions, TableType, TileMatrix, TileMetadata}
+import org.apache.sedona.sql.datasources.geopackage.model.{GeoPackageField, TableType, TileMatrix, TileMetadata}
 import org.apache.sedona.sql.datasources.geopackage.model.TableType.TableType
-import org.apache.spark.sql.connector.read.InputPartition
-import org.apache.spark.sql.execution.datasources.PartitionedFile
 
-import java.io.FileOutputStream
 import java.sql.{Connection, DriverManager, ResultSet, Statement}
 import scala.collection.mutable
 import scala.collection.mutable.ArrayBuffer
@@ -41,21 +36,6 @@ object GeoPackageConnectionManager {
     st.close()
   }
 
-  def getTableCursor(partitionOptions: InputPartition): ResultSet = {
-//    val conn: Connection =
-//      DriverManager.getConnection("jdbc:sqlite:" + partitionOptions.loadOptions.path)
-//    val stmt: Statement = conn.createStatement()
-//    stmt.executeQuery(s"SELECT * FROM ${partitionOptions.loadOptions.tableName}")
-    return null
-  }
-
-//  def getTableCursor(partitionOptions: PartitionOptions): ResultSet = {
-//    val conn: Connection =
-//      DriverManager.getConnection("jdbc:sqlite:" + partitionOptions.loadOptions.path)
-//    val stmt: Statement = conn.createStatement()
-//    stmt.executeQuery(s"SELECT * FROM ${partitionOptions.loadOptions.tableName}")
-//  }
-
   def getTableCursor(path: String, tableName: String): ResultSet = {
     val conn: Connection =
       DriverManager.getConnection("jdbc:sqlite:" + path)