如何從Pyspark

Question

更新MySQL表數據我能夠通過

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

閱讀從pyspark MySQL表數據，但我不能找到一種方法，在mysql中更新記錄。有沒有人曾經從pyspark進行過更新。

Answer 1

不允許更新。您只可以：

• append。
• overwrite

更新或其它細粒度的修改直接使用標準的數據庫客戶端。