Я пытаюсь прочитать данные из Hive и запись в пользовательский объект в Salesforce, используя диск JDBC для Salesforce из Progress. Вот как я пытаюсь это сделать
spark-shell --jars /usr/hdp/current/spark-client/lib/sforce.jar
import org.apache.spark.sql.hive._
val hc = new HiveContext(sc)
val results = hc.sql("select rep_name FROM schema.rpt_view")
print(results.first())
import org.apache.spark.sql.SaveMode
val url="jdbc:datadirect:sforce://login.salesforce.com"
val prop = new java.util.Properties
prop.put("user","user1")
prop.put("password","passwd")
prop.put("driver","com.ddtek.jdbc.sforce.SForceDriver")
results.write.mode(SaveMode.Append).jdbc(url,"SFORCE.test_tab1",prop)`
Я получаю ошибку
`java.sql.SQLSyntaxErrorException: [DataDirect][SForce JDBC Driver][SForce]column size is required in statement [CREATE TABLE SFORCE.test_tab1 (rep_name TEXT`
Может ли кто-нибудь мне помочь здесь .. если таблица test_tab1 уже существует, как мне настроить запись, а также, если таблица не существует в Salesforce, как добавить значение столбца