ошибка после обновления спарк до версии 2.4

Question

Я недавно обновил свою версию Spark с 2.2 до 2.4.0

У меня возникла ошибка в этом блоке (которая работала нормально с версией 2.2):

object Crud_mod {

  def f(df: DataFrame,
               options: JDBCOptions,
               conditions: List[String]) {
    val url = options.url
    val tables = options.table
    val dialect = JdbcDialects_mod.get(url)

error: value table is not a member of org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions
[ERROR]     val tables = options.table

Итак, я Заглянул внутрь Источники искр и значение table, похоже, существует в JDBCOptions классе.

Что мне не хватает, пожалуйста?

Answer 1

Ваша ссылка на источники указывает на конструктор, который принимает table в качестве аргумента, но я не могу найти значение table в самом классе. Однако есть метод tableOrQuery ( здесь ), который, я думаю, можно использовать для ваших нужд.