我们如何使用cassandra中的rowUpdateBuilder写入包含复合分区键的审计表？

Question

我在网上看到了各种使用cassandra触发器写入审计表的例子。我一直在关注这一点：https://github.com/apache/cassandra/blob/cassandra-3.0/examples/triggers/src/org/apache/cassandra/triggers/AuditTrigger.java

然而，在我的用例中，我有一个审计表，它有一个复合分区键（主键（（col1，col2），col3，col4））和多个集群列。我已经能够通过添加审计来添加集群列。集群（值），但我不知道如何实现复合分区键。如果我通过更新，RowUpdateBuilder会给我一个错误。分区键。partition（）作为rowUpdateBuilder的第三个参数。

错误是： Java.lang.IllegalArgumentExcoop：无效的组件数量，预期为2，但得到1。

当我将大小为2的数组作为第三个参数传递给rowUpdateBuilder时，我得到了同样的错误。

任何帮助都将不胜感激。

Answer 1

从所有分区密钥生成复合分区密钥

要从一个或多个分区键生成复合分区键，请使用以下方法：

public DecoratedKey buildCompositePartitionKey(CFMetaData metadata, Object... partitionKey) {
    return metadata.decorateKey(
            CFMetaData.serializePartitionKey(
                    metadata.getKeyValidatorAsClusteringComparator().make(partitionKey)
            )
    );
}

示例：

CFMetaData metadata = Schema.instance.getCFMetaData("test_ks", "test_cf");
DecoratedKey compositePartitionKey = buildCompositePartitionKey(metadata, "col1 value", "col2 value");
RowUpdateBuilder audit = new RowUpdateBuilder(metadata, FBUtilities.timestampMicros(), compositePartitionKey);