java - Cassandra 3.x 触发器列值

Question

我正在使用 3.4 Cassandra 触发器 API，它引入了修改后的 ITrigger 接口(interface)，例如:https://github.com/apache/cassandra/blob/trunk/examples/triggers/src/org/apache/cassandra/triggers/AuditTrigger.java

我的问题是如何从 Partition 对象中提取插入/更新语句的列值？如果是这样我该怎么做？

public interface ITrigger
{
    public Collection<Mutation> augment(Partition update);
}

一些代码片段会很有用。

Answer 1

试试这个!!!

public Collection<Mutation> augment(Partition update) {
    try {
        UnfilteredRowIterator it = update.unfilteredIterator();
        while (it.hasNext()) {
            Unfiltered un = it.next();
            Clustering clt = (Clustering) un.clustering();  
            Iterator<Cell> cls = update.getRow(clt).cells().iterator();
            while(cls.hasNext()){
                Cell cell = cls.next();
                 String data = new String(cell.value().array()); // If cell type is text
            }
        }
    } catch (Exception e) {
      ...
    }
    return null;
}