谢谢你阅读这个问题。
我知道如何插入行
df.write \
.format('jdbc') \
.option("url", url) \
.option("dbtable", table) \
.option("user", user) \
.option("password", password) \
.option("driver", "org.postgresql.Driver") \
.mode('append') \
.save()
但是如何删除行呢?就像。。
df = [Row(id=1), Row(id=2), ... ]
=> DELETE FROM TABLE WHERE id in df ...
有可能吗?
1条答案
按热度按时间ygya80vv1#
spark不支持。但是我已经用foreachpartition完成了(只使用dataframe数据…)
apachesparksql是否支持merge子句?