功能 deleteFromCassandra() 为了删除Cassandra记录是在新的Cassandra连接器释放来。请查看sparkc-349和sparkc-392了解更多详细信息。
要使用cassandra连接器从cassandra中删除行，可以执行以下操作。例如，我有如下列 id UUID PRIMARY KEY, username TEXT 在我的table上。现在我想删除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();
    });