1

我正在开发一个项目，在该项目中，我需要使用 Astyanax 客户端删除所有列及其数据，但 Cassandra 中的一列及其数据除外。

我有一个像下面这样的动态列族，我们已经有几百万条记录到该列族中。

create column family USER_TEST
with key_validation_class = 'UTF8Type'
and comparator = 'UTF8Type'
and default_validation_class = 'UTF8Type'
and gc_grace = 86400
and column_metadata = [ {column_name : 'lmd', validation_class : DateType}];

我拥有user_id的 rowKey 和其他列是这样的 -

a1,a2,a3,a4,a5,a6,a7,a8,a9,a10,a11,a12,a13,a14,a15,lmd

现在我需要删除除列之外的所有列及其数据a15。意思是，我想保留a15所有列及其数据，user_id(rowKey)并删除其余列及其数据。

我已经知道如何使用 Astyanax 客户端从 Cassandra 中删除特定数据rowKey-

public void deleteRecord(final String rowKey) {

    try {
        MutationBatch m = AstyanaxConnection.getInstance().getKeyspace().prepareMutationBatch();

        m.withRow(AstyanaxConnection.getInstance().getEmp_cf(), rowKey).delete();

        m.execute();

    } catch (ConnectionException e) {
        // some code
    } catch (Exception e) {
        // some code
    }
}

现在如何删除所有列及其数据，除了所有用户 id 的一列，即我的 rowKey ...

有什么想法可以有效地使用 Astyanax 客户端完成吗？

4

1 回答 1

2

Astyanax 目前似乎不支持存储引擎和 Thrift API 中最近添加的切片删除功能。如果您查看 thrift API 参考：http ://wiki.apache.org/cassandra/API10 您会看到删除操作采用 SlicePredicate，它可以采用列列表或 SliceRange。SliceRange 可以指定大于或小于您要保留的列的所有列，这样您就可以执行两次切片删除操作来删除行中除一列之外的所有列。

不幸的是，Astyanax 只能删除整行或定义的列列表，并且不包含完整的 SlicePredicate 功能。所以看起来你有两个选择：1）请参阅发送原始节俭切片删除，绕过 Astyanax 包装器，或 2）执行列读取，然后是行删除，然后是列写入。这不是理想的效率，但如果不经常这样做，也不应该禁止。或 3) 读取整行并明确删除除您要保留的列之外的所有列。

我应该注意到，虽然存储引擎和 thrift API 都支持切片删除，但 CQL 还没有明确支持这一点。

我提交了这张票以解决最后一个限制： https ://issues.apache.org/jira/browse/CASSANDRA-6292

于 2013-11-03T03:25:50.057 回答