我在Accumulo的表中插入了一些行。有些行是新创建的,有些行是更新的。
如何找到插入或更新到Java中的accumulo表?
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++;
}
这是当前正在执行的操作,计数被视为写入表中的条目数。但是,如果只插入了一些新条目/行,而其他条目/行要更新,则不能将计数视为输入到表中的新条目
从Accumulo 1.6.x(截至本文的最新版本)开始,没有用于获取表中行或单个条目计数的公共API。如果维护计数是一项内置功能,则会增加一些开销,并且很难实现,因为服务器端迭代器可以在压缩期间更改这些计数。
因此,Accumulo 提供的最佳值是对表中条目数的估计值(仅条目,而不是行)。
如果需要行计数,则必须在应用程序层添加该功能。可以在用户邮件列表中获得有关执行此操作的帮助。