Skip to content

Commit

Permalink
Retrieve provider from properties
Browse files Browse the repository at this point in the history
  • Loading branch information
osopardo1 committed Jan 14, 2025
1 parent ed4dc38 commit 6e7b844
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions src/main/scala/io/qbeast/sources/QbeastDataSource.scala
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@
*/
package io.qbeast.sources

import io.qbeast.catalog.QbeastCatalogUtils.QBEAST_PROVIDER_NAME
import io.qbeast.context.QbeastContext
import io.qbeast.core.model.QbeastOptions
import io.qbeast.sources.v2.QbeastTableImpl
Expand Down Expand Up @@ -90,8 +91,8 @@ class QbeastDataSource private[sources] (private val tableFactory: IndexedTableF
} else {
// If the table does not exist, we create a new one with the properties passed
val tableProperties = properties.asScala.toMap
val qbeastOptions = QbeastOptions(tableProperties)
val tableProvider = qbeastOptions.tableFormat
val tableProvider =
tableProperties.getOrElse(QbeastOptions.TABLE_FORMAT, QBEAST_PROVIDER_NAME)
val tableIdentifier = TableIdentifier(tableId.id)
QbeastTableImpl(
tableIdentifier,
Expand Down

0 comments on commit 6e7b844

Please sign in to comment.