如何获得整个keySet集群的keySet()和size()？

Question

GridCache.keySet()、.primarySize()和.size()只返回该节点的信息。

除了整个集群之外，我如何获取这些信息？

扫描整个集群“有效”，但我所需要的只是键或计数，而不是值。

问题是，如果我想要基于索引字段查找，则SQL查询可以工作，但无法根据网格缓存条目键本身找到。

我的解决办法是有效的，但远远没有优雅和表演性：

Set<String> ruleIds = FluentIterable.from(cache.queries().createSqlFieldsQuery("SELECT property FROM YagoRule").execute().get())
        .<String>transform((it) -> (String) it.iterator().next()).toSet();

这要求键与字段中的一个相同，而且由于性能原因，需要对字段进行索引。

Answer 1

GridGain的下一个版本(6.2.0)将有globalSize()和globalPrimarySize()方法，它们将询问集群的大小。

现在，您可以使用以下代码：

// Only grab nodes on which cache "mycache" is started.
GridCompute compute = grid.forCache("mycache").compute();

Collection<Integer> res = compute.broadcast(
    // This code will execute on every caching node.
    new GridCallable<Integer>() {
         @Override public Integer call() {
             return grid.cache("mycache").size();
         }
    }
).get();

int sum = 0;

for (Integer i : res)
    sum += i;