Создать индекс через SPARK для JDBC - PullRequest
0 голосов
/ 13 декабря 2018

Я пытаюсь создать индекс на Postgres Table через Spark, а код выглядит следующим образом:

   val df3 = sqlContext.read.format("jdbc")
  .option("url", "jdbc:postgresql://URL")                                                          
   .option("user", "user")
  .option("password", "password")
  .option("dbtable", "(ALTER TABLE abc.test1 ADD PRIMARY KEY (test))as t")
  .option("driver", "org.postgresql.Driver")
  .option("lowerBound", 1L)
  .option("upperBound", 10000000L)
  .option("numPartitions", 100)
  .option("fetchSize", "1000000")
  .load()

Ошибка

Исключение в потоке "main" org.postgresql.util.PSQLException: ОШИБКА: синтаксическая ошибка в или около "TABLE"

Просто интересно, можем ли мы это сделать, или приведенный выше кадр данных неверен.Ценю вашу помощь.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...