Cassandra 触发器是异步的吗？

Question

我正在测试 cassandra 触发器并实现了ITrigger 接口。 如票上https://issues.apache.org/jira/browse/CASSANDRA-1311 似乎 cassandra 触发器应该是异步的，这意味着在客户端进行插入后，客户端不应等待触发器被执行。

但是我在触发器中添加了 15 秒的睡眠，并且插入操作由于超时而失败。所以它似乎在等待触发器完成它的工作。

有没有办法让触发器异步工作？ （根据我读过的页面，它应该已经是异步的了）

Answer 1

不，默认情况下 Cassandra 等待触发器执行。

但是您可以使用带有QueryProcessor 的执行查询来更改它并运行到单独的线程中。请注意，如果您这样做并且触发器执行失败，您将无法从主查询中知道触发器查询失败。

Cassandra 2.x 示例：

@Override
public Collection<Mutation> augment(ByteBuffer key, ColumnFamily update) {
     new Thread(new Runnable() {
        @Override
        public void run() {
            //build your own query from the ByteBuffer key and ColumnFamily  update
            Insert insert = QueryBuilder.insertInto("test_keyspace.test_table").value("id", 1).value("data", "Test");

            //execute query  
            QueryProcessor.process(insert.toString(), ConsistencyLevel.LOCAL_QUORUM);
        }
    }).start();
    return Collections.EMPTY_LIST;
}