java - 插入表中的行数(累加)

标签 java accumulo

我已将一些行插入到 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(截至本文为止的最新版本)开始,没有公共(public) API 用于获取表中的行数或单个条目的计数。如果维护计数是一个内置功能,那么它会增加一些开销,并且很难实现,因为服务器端迭代器可能会在压缩期间更改这些计数。

因此,Accumulo 提供的最佳功能是估计表中的条目数(仅条目,而不是行)。

如果需要行计数,则必须在应用程序层添加该功能。可以在 user mailing list 上找到执行此操作的帮助。 .

关于java - 插入表中的行数(累加),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29906366/

相关文章:

java - 获取 Accumulo 实例名称

java - 如何通过改造接收来自服务器的消息?

java - 累积API : When Does a Scanner Initially Communicate With Accumulo?

java - 如何将Java项目导出到可运行的jar资源中?

java - 在服务器刷新数据之前,套接字如何从服务器接收数据?

java - Accumulo MapReduce 作业因 java.io.EOFException 而失败,使用 AccumuloRowInputFormat

java - Accumulo,使用 TransformingIterator 修改先前的键

java - 需要在实现中抛出检查异常,但接口(interface)没有抛出该异常?

java - 提供静态(默认)值的最佳方法

java - 为什么下面for循环中的 “getPassenger()”方法可以直接调用而不需要先创建对象?