java - 如何使用 cassandra 触发器执行删除操作？

Question

我在一个键空间中有两个列族。这些列族具有相同的模式和数据。当对第一个执行删除操作时，我想删除第二个具有相同主键的行。这是我在 ITrigger 增强方法上尝试过的方法

@Override
public Collection<Mutation> augment(ByteBuffer key, ColumnFamily update) {
    List<Mutation> mutations = new ArrayList<>(update.getColumnCount());
    String indexKeySpace = properties.getProperty("keyspace");
    String indexColumnFamily = properties.getProperty("table");
    if (!update.deletionInfo().isLive()) {
        Mutation mutation = new Mutation(indexKeySpace, key);
        mutation.delete(indexColumnFamily, System.currentTimeMillis());
        mutations.add(mutation);
    }
    return mutations;
}

Answer 1

我修好了:D
这是工作代码

@Override
public Collection<Mutation> augment(ByteBuffer key, ColumnFamily update) {
    List<Mutation> mutations = new ArrayList<>(update.getColumnCount());
    String indexKeySpace = properties.getProperty("keyspace");
    String indexColumnFamily = properties.getProperty("table");
    if (!update.deletionInfo().isLive()) {
        CFMetaData cfMetaData = Schema.instance.getCFMetaData(indexKeySpace, indexColumnFamily);
        for (ColumnDefinition columnDefinition : cfMetaData.allColumns()) {
            Mutation mutation = new Mutation(indexKeySpace, key);
            mutation.delete(indexColumnFamily, CellNames.simpleSparse(columnDefinition.name), System.currentTimeMillis());
            mutations.add(mutation);
        }
    }
    return mutations;
}