Delete checks

Qbeast-io · Dec 7, 2023 · ea11e90 · ea11e90
1 parent b48074e
commit ea11e90
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 12 deletions.
diff --git a/src/main/scala/io/qbeast/spark/internal/QbeastOptions.scala b/src/main/scala/io/qbeast/spark/internal/QbeastOptions.scala
@@ -131,10 +131,4 @@ object QbeastOptions {
         }))
   }
 
-  def checkQbeastProperties(parameters: Map[String, String]): Unit = {
-    require(
-      parameters.contains("columnsToIndex") || parameters.contains("columnstoindex"),
-      throw AnalysisExceptionFactory.create("'columnsToIndex is not specified"))
-  }
-
 }
diff --git a/src/main/scala/io/qbeast/spark/internal/sources/catalog/QbeastCatalog.scala b/src/main/scala/io/qbeast/spark/internal/sources/catalog/QbeastCatalog.scala
@@ -6,7 +6,6 @@ package io.qbeast.spark.internal.sources.catalog
 import io.qbeast.context.QbeastContext
 import io.qbeast.spark.internal.sources.v2.QbeastStagedTableImpl
 import io.qbeast.spark.internal.sources.v2.QbeastTableImpl
-import io.qbeast.spark.internal.QbeastOptions.checkQbeastProperties
 import org.apache.hadoop.fs.Path
 import org.apache.spark.sql.catalyst.analysis.NoSuchDatabaseException
 import org.apache.spark.sql.catalyst.analysis.NoSuchNamespaceException
@@ -109,7 +108,6 @@ class QbeastCatalog[T <: TableCatalog with SupportsNamespaces with FunctionCatal
       properties: util.Map[String, String]): Table = {
 
     if (QbeastCatalogUtils.isQbeastProvider(properties)) {
-      checkQbeastProperties(properties.asScala.toMap)
       // Create the table
       QbeastCatalogUtils.createQbeastTable(
         ident,

diff --git a/src/main/scala/io/qbeast/spark/internal/sources/v2/QbeastStagedTableImpl.scala b/src/main/scala/io/qbeast/spark/internal/sources/v2/QbeastStagedTableImpl.scala
@@ -5,7 +5,6 @@ package io.qbeast.spark.internal.sources.v2
 
 import io.qbeast.spark.internal.sources.catalog.CreationMode
 import io.qbeast.spark.internal.sources.catalog.QbeastCatalogUtils
-import io.qbeast.spark.internal.QbeastOptions.checkQbeastProperties
 import io.qbeast.spark.table.IndexedTableFactory
 import org.apache.spark.sql.catalyst.catalog.SessionCatalog
 import org.apache.spark.sql.connector.catalog.Identifier
@@ -72,9 +71,6 @@ private[sources] class QbeastStagedTableImpl(
     // we pass all the writeOptions to the properties as well
     writeOptions.foreach { case (k, v) => props.put(k, v) }
 
-    // Check all the Qbeast properties are correctly specified
-    checkQbeastProperties(props.asScala.toMap)
-
     // Creates the corresponding table on the Catalog and executes
     // the writing of the dataFrame (if any)
     QbeastCatalogUtils.createQbeastTable(