首页 文章

Spark Cassandra连接器仅在存在时更新

提问于
浏览
0

使用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 回答

相关问题