java - 用于获取删除的行和列值的 Cassandra 示例触发器

标签 java cassandra cassandra-2.0

当列族中有更新时,会调用 ITrigger 扩充方法。我们如何知道更新操作是插入还是删除?

此外,是否可以在触发器实现中的同一键空间中的其他表中执行任何 DML 语句?假设有两个表test1和test2。为 test1 创建触发器。如果test1中有删除操作,我们如何在触发器实现中执行test2的DML语句?

最佳答案

这里是检查更新操作是删除还是插入的代码

@Override
public Collection<Mutation> augment(ByteBuffer key, ColumnFamily update) {
    if (!update.deletionInfo().isLive()) {
        System.out.println("Delete Operation");
    } else {
        System.out.println("Insert Operation");
    }
}

关于java - 用于获取删除的行和列值的 Cassandra 示例触发器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31722332/

相关文章:

java - SSTable 加载器流式传输失败,出现 java.io.IOException : Connection reset by peer

java - 告诉 Java 不要重绘

java - 将各种类型的函数应用于值

java - 关闭 CloseableHttpResponse/CloseableHttpClient 的正确方法

java - Cassandra-Java-driver : com. datastax.driver.core.exceptions.InvalidTypeException : Invalid type, 列是一个列表,但提供了类 java.lang.String

cassandra - 刷新期间 cassandra 的所有提交日志功能和行为

java - kafka(不活动)消费者滞后监控

Cassandra读取进程

python - 如何从 python cassandra 驱动程序传递 cassandra 函数?

apache-spark - spark 中 cassandra 行的写入时间