使用Spark Cassandra Connector,我有一个案例,我想使用UPDATE IF EXISTS,如果表中不存在则忽略 .
在Cassandra documentation中,我们在Cassandra 2.0.7及更高版本中具有此条件,您可以使用IF或IF EXISTS有条件地更新列 .
将IF EXISTS添加到命令中以确保在指定的行不存在时不执行操作:UPDATE cycling.cyclist_id SET age = 28 WHERE lastname ='WELTEN'和firstname ='Bram'IF EXISTS;
但是,我不清楚这是否可以在Spark Cassandra Connector中完成 . 有谁知道如何做到这一点?
1 回答
看起来它不是现在可以做的事情,但它是一个悬而未决的问题 .
https://datastax-oss.atlassian.net/browse/SPARKC-386 - 安德鲁米尔斯回答