SparkからTeradataテーブルにデータフレームを書き込む

Question

これまでのところ、Teradataからデータフレームを読み取り、Spark用のTeradata jdbcコネクタを使用することができます。次のように読書のための 構文は次のとおりです。Teradataの

ため

val df = hc.read.format("jdbc").options(
    Map(
    "url" -> url, 
    "dbtable" -> (sel * from tableA) as data, 
    "driver" -> "com.teradata.jdbc.TeraDriver" 
) 
).load() 

HC = hiveContext、URL =接続URL私がTeradata表にデータフレームを保存します。私は、ステートメントを挿入しDBTABLE変更することにより、上記の構文を使用してみました

val df = hc.read.format("jdbc").options(
    Map(
    "url" -> url, 
    "dbtable" -> (insert into db.tabA values (1,2,3)) as data, 
    "driver" -> "com.teradata.jdbc.TeraDriver" 
) 
).load() 

しかし、上記の文は私にエラーを与えた：

Error: Exception in thread "main" java.sql.SQLException: [Teradata Database] [TeraJDBC 15.10.00.22] [Error 3706] [SQLState 42000] Syntax error: expected something between '(' and the 'insert' keyword. 

私はスパークでのTeradataへのデータフレームを保存したい、何ですそれを行う最良の方法？

Answer 1

AFAIK as dataが正しくない、残っているように見えます。以下は

"dbtable" -> (insert into db.tabA values (1,2,3)) , 

と

"dbtable" -> (insert into db.tabA values (1,2,3)) as data, 

は、任意の手間アウトで動作するはずです。

val df = hc.read.format("jdbc").options(
    Map(
    "url" -> url, 
    "dbtable" -> (insert into db.tabA values (1,2,3)), 
    "driver" -> "com.teradata.jdbc.TeraDriver" 
) 
).load() 

Answer 2

Scalikejdbcを使用してTeradataテーブルにデータを書き込むことができました。 私はバッチ更新を使用して結果を保存しています。 ScalikeJdbc使用してバッチ行を挿入するための

サンプルコード：

DB localTx { implicit session => 
    val batchParams: Seq[Seq[Any]] = (2001 to 3000).map(i => Seq(i, "name" + i)) 
    withSQL { 
    insert.into(Emp).namedValues(column.id -> sqls.?, column.name -> sqls.?) 
    }.batch(batchParams: _*).apply() 
}