2016-12-17 17 views
1

からMySQLのテーブル内のデータを更新するにはどうすればPyspark

hiveContext.read.format('jdbc').options(url=jdbc_url, dbtable=mysql_query,driver='com.mysql.jdbc.Driver').load() 

経由pysparkでmysqlのテーブルからデータを読み取ることができるが、私は、MySQL内のレコードを更新する方法を見つけることができないのです。誰もがpysparkからアップデートを実行したことがあります。

答えて

1

更新は許可されていません。あなたはできる:

  • append。更新や他のきめの細かい変更については
  • overwrite

直接標準のデータベース・クライアントを使用しています。