Я пытаюсь создать индекс на 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"
Просто интересно, можем ли мы это сделать, или приведенный выше кадр данных неверен.Ценю вашу помощь.