mysql - 如何从 Pyspark 更新 Mysql 表中的数据

Question

我可以通过

从 pyspark 中的 mysql 表中读取数据

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

但我无法找到一种方法来更新 mysql 中的记录。有没有人从 pyspark 执行过更新。

Answer 1

不允许更新。您只能:

• 追加。
• 覆盖

对于更新或其他细粒度修改，直接使用标准数据库客户端。