我正在尝试使用RowDeletingIterator删除Accumulo表中的条目,但是此后扫描表时,这些条目不会被删除。假设表row_id中有一个tableName条目,这就是我正在做的事情: Connection connection = new ZooKeeperInstance(instance, zookeepers).getConnector(username, new PasswordToken(password)); String tableName = "tableName"; connectio…

2020年10月16日 0条评论 14点热度 阅读全文

当我构建accummulo-1.4.3-cdh43.tar.gz中包含的示例简单Maven项目时 我正在使用设置为jdk1.6.0.32的Java平台的netbeans。 我因错误的测试而导致测试失败:test(org.apache.accumulo.examples.simple.filedata.ChunkInputFormatTest) 这是输出: T E S T S 运行org.apache.accumulo.examples.simple.filedata.ChunkInputFormatTest测试运行…

2020年9月4日 0条评论 21点热度 阅读全文

我正在寻找编写Accumulo迭代器以返回表的百分位数的随机样本。 我将不胜感激任何建议。 na, 克里斯 解决方案如下: 您可以扩展org.apache.accumulo.core.iterators.Filter并随机接受x%的条目。以下迭代器将随机返回条目的5%。 import java.util.Random; import org.apache.accumulo.core.data.Key; import org.apache.accumulo.core.data.Value; import org.ap…

2020年7月14日 0条评论 17点热度 阅读全文

我的所有映射器均失败,但以下情况除外。为简洁起见,我仅显示了最后一次失败。 为什么会发生这种情况,我该如何解决? 16/09/21 17:01:57 INFO mapred.JobClient: Task Id : attempt_201609151451_0044_m_000002_2, Status : FAILED java.io.EOFException at java.io.DataInputStream.readFully(DataInputStream.java:197) at java.io.Dat…

2020年7月9日 0条评论 16点热度 阅读全文

我正在尝试将bash脚本转换为Java程序。在此脚本中,我运行Hadoop,Zookeeper和Accumulo的启动脚本: /hadoop/bin/start_all.sh /zookeeper/bin/zkServer.sh start /accumulo/bin/start_all.sh 这在脚本中很简单。如果程序已经在运行,则可以再次调用这些启动脚本,而程序将仅输出它们已经在运行以及它们的pid。 我试图找出是否有一种方法可以在Java程序中执行此操作。 在Hadoop / ZooKeeper / Accu…

2020年6月13日 0条评论 26点热度 阅读全文

我正在尝试创建一个自定义迭代器,但是由于没有可用的教程,因此我查看了Accumulo github页面上提供的代码。 在那里,我发现所有类都实现了SortedKeyValueIterator并覆盖了其功能。 这些函数的作用是什么,在创建实现SortedKeyValueIterator的新类时覆盖这些函数时应采用的方法是什么。 这是我试图理解的RowFilter类的示例代码。 public void init(SortedKeyValueIterator<Key,Value> source, Map<…

2020年6月9日 0条评论 21点热度 阅读全文

我正在尝试查询要使用Windows客户端PC [Casa-PC]进行测试的PC服务器[JARVIS](在具有Ubuntu Server 14.04.3的PC上使用Apache 1.7.0累积-Zookeper 3.4.6- Hadoop 2.7.1)。 PC](在Eclipse中制造,我在该项目中执行了一个带有maven库Accumulation-1.7.0和hadoop-core-1.2.1的项目),它们都在同一LAN上。当我尝试使用以下代码查询PC服务器时,在PC客户端上运行Java Eclipse将我带回以下…

2020年5月28日 0条评论 11点热度 阅读全文

我正在从出现此错误的用户手册中运行一些基本的Accumulo代码。 一个简单的谷歌搜索没有提供任何有用的东西。 错误 org.apache.accumulo.core.client.AccumuloException: org.apache.thrift.TApplicationException: Invalid method name: 'authenticate' at org.apache.accumulo.core.client.impl.ServerClient.execute(ServerClient…

2020年3月22日 0条评论 17点热度 阅读全文

假设我在Accumulo中有一个这样的表: a cf1:cq1 [ ] 1 b cf1:cq1 [ ] 3 c cf1:cq1 [ ] 2 如果我在此表上应用SummingCombiner并插入“ a cf1 cq1 2”行,则结果将为: a cf1:cq1 [ ] 3 b cf1:cq1 [ ] 3 c cf1:cq1 [ ] 2 我想知道的是,是否有一个迭代器可以帮助我在诸如列限定符之类的特定字段上执行聚合。 简而言之,我可以执行类似“ Sum of the values of those rows where…

2020年3月5日 0条评论 21点热度 阅读全文

我正在慢慢学习Accumulo命令,并遇到运行Apache Hello World示例将批处理的10K行(50K条目)批量提取到累积中的问题。 https://accumulo.apache.org/1.7/examples/我使用uno构建来启动并运行HDFS,zookeeper和Accumulo(2.0)。我可以使用网络浏览器连接到hadoop和Accumulo。我可以通过shell登录到Accumulo,并成功创建了可问候表。然后,来自Apache示例的指令说要启动用BatchWriter批量插入的Java程…

2019年12月27日 0条评论 18点热度 阅读全文