使用Apache Spark Java connector for Cassandra使用键列从Cassandra DB中删除行

Question

我正在使用Apache Spark 2.0、Apache Cassandra 3.7和Apache Spark Java Connector for Cassandra 2.11(2.0.0-M3)

Answer 1

用于删除Cassandra记录的功能deletefromcassandra()将在新的Cassandra连接器版本中发布。更多详情请查看SPARKC-349和SPARKC-392。

要使用Cassandra连接器从Cassandra中删除行，可以执行如下操作。例如，我的表中有id UUID PRIMARY KEY，username text等列。现在我想删除所有username等于“mat”的行。为此，从Cassandra连接器获取会话并执行delete查询。

dataset.where(dataset.col("username").equalTo("Mat")).foreachPartition(partition -> {
Session session = connector.openSession();
        while (partition.hasNext()) {
            Row row = partition.next();
            String id = (String) row.get(0);//UUID is at index 0
            String delete = "DELETE FROM mykeyspace.mytable where id=" + id + ";";
            session.execute(delete);
        }
        session.close();
    });