Cassandra：如何从 Java 中的本地节点查询本地 Table？

Question

我有一个复制因子为 2 的三节点集群，我想从键空间“system”接收 table local。 这意味着我想访问 Cassandra 节点的本地数据。 这可能吗？

Answer 1

是的。您可以从 Java 中查询 system.local table，就像查询其他查询一样。

    session = cluster.connect();
    ResultSet results = getSession()
        .execute("SELECT key,broadcast_address,cql_version FROM system.local");

    for (Row row : results) {
        System.out.println(row.getString("key") + " "
            + row.getInet("broadcast_address") + " "
            + row.getString("cql_version"));
    }

local 127.0.0.1 3.4.4