计算 Accumulo 批处理扫描仪返回的行数

Question

我想知道是否有一种有效的方法来计算 Accumulo 中的批处理扫描仪返回的行数，而无需手动遍历所有返回的行。

我现在的东西是这样的

Connector connector = // Created a new connector
BatchScanner bsc = connector.createBatchScanner(tableName, Authorizations.EMPTY, numThreads);
/*
... applying filters
*/

Iterator<Map.Entry<Key, Value>> e = bsc.iterator();
long cnt = 0;

while(e.hasNext()) {
     cnt++;
}

return cnt;

我正在遍历批处理扫描器返回的每一行并计算我遇到的每一行。我想知道是否有更好的方法来做到这一点？

Answer 1

通常 (What is the best way to get the count/length/size of an iterator?) 您将无法更快地执行此操作，因为您的过滤器可以是任何东西，因此您将不得不在某个地方进行一些计数。

您可以通过其他方式 (Maintain statistics across rows in accumulo) 跟踪计数，但它们可能会给您带来新的麻烦。