accumulo 中插入 table 的行数

Question

我在 Accumulo 中的 table 中插入了一些行。有些行是新创建的，有些行是更新的。

如何找到插入或更新到在 Java?

中累积 table

def obj= jsonObject["obj"]
for(entry in obj) {
                String a = entry["a"];
                String b = entry["b"];
                String c = entry["c"];
                String d = entry["d"];
                String e = entry["e"];

                ColumnVisibility cv = new ColumnVisibility(d);
                Mutation m = new Mutation(a);
                m.put(b, c, cv, e)
                bw.addMutation(m);
                count++;
            }

这是当前正在执行的操作，计数被视为写入 table 的条目数。但是如果只有一些新的entry/rows被插入而其他的要被更新，这个计数不能被认为是新进入table

的条目

Answer 1

从 Accumulo 1.6.x（最新的，截至此 post），没有 public API 用于获取行数或table 中的个别条目。如果维护计数是一项内置功能，它会增加一些开销，并且很难实现，因为服务器端迭代器可能会在压缩期间更改这些计数。

因此，Accumulo 提供的最佳方法是估计 table 中的条目数（仅条目，而非行）。

如果需要行计数，则必须在应用层添加该功能。可以在 user mailing list.

上获得帮助以执行此操作

accumulo 中插入 table 的行数

count of rows inserted into a table in accumulo

java

accumulo