从pyspark重写cassandra表时出错

i2byvkas 于 2021-06-14 发布在 Cassandra

关注(0)|答案(1)|浏览(672)

我正试图用pysparkDataframe覆盖cassandra中的数据。我得到这个错误：关键字不能是表达式
我可以通过 df.write.format("org.apache.spark.sql.cassandra").options(keyspace="ks",table="testtable").mode("append").save() 但是，覆盖是抛出错误 df.write.format("org.apache.spark.sql.cassandra").options(keyspace="ks",table="testtable", confirm.truncate="true").mode("overwrite").save() 错误：关键字不能是表达式

cassandra pyspark spark-cassandra-connector

来源：https://stackoverflow.com/questions/57580197/error-while-overwriting-cassandra-table-from-pyspark

1条答案

按热度按时间

yiytaume1#

我找到了解决办法。

df.write.format("org.apache.spark.sql.cassandra")
.mode("overwrite").option("confirm.truncate","true")
.options(keyspace="ks",table="testtable")
.save()

赞(0）回复(0）举报 2021-06-14

我来回答

从pyspark重写cassandra表时出错

1条答案

相关问题

热门标签

最新问答