1

我正在尝试创建一个自定义迭代器，但由于没有可用的教程，我查看了 Accumulo github 页面上提供的代码。

在那里我发现所有类都实现了 SortedKeyValueIterator 并覆盖了它的功能。

这些函数的作用是什么，在创建实现 SortedKeyValueIterator 的新类时重写这些函数时应该采用什么方法。

这是我试图理解的 RowFilter 类的示例代码。

 public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options, IteratorEnvironment env) throws IOException {
super.init(source, options, env);
this.decisionIterator = new RowIterator(source.deepCopy(env));
}

 public SortedKeyValueIterator<Key,Value> deepCopy(IteratorEnvironment env) {
 RowFilter newInstance;
 try {
       newInstance = getClass().newInstance();
     } catch (Exception e) 
      {
         throw new RuntimeException(e);
      }
  newInstance.setSource(getSource().deepCopy(env));
  newInstance.decisionIterator = new RowIterator(getSource().deepCopy(env));
  return newInstance;
   }

我想知道，这段代码做了什么，如果我想要另一个类来实现 SortedKeyValueIterator，我应该如何覆盖这些函数。

4

1 回答 1

4

从查看 SortedKeyValueIterator 上的 Javadoc 开始——http ://accumulo.apache.org/1.6/apidocs/。对于每种方法应该做什么，这是一个很好的起点。

编写迭代器的一个很好的类比是将您的 Accumulo 表（迭代器正在对其进行操作）视为单链表（按排序顺序）。next() 移动到列表中的下一个节点，而 seek() 向前/向下移动，从零跳到多个节点。init() 从 Accumulo 表配置和客户端提供任何必要的配置（您的迭代器可能在 Accumulo 服务器中运行）。deepCopy() 应该将当前迭代器的确切状态复制到一个新实例中（类似于 Object.clone()）。

我还可以提供两个自定义迭代器的示例：

您还可以查看 Accumulo http://accumulo.apache.org/1.6/apidocs/org/apache/accumulo/core/iterators/user/package-summary.html中提供的其他“面向用户”的迭代器

于 2015-01-07T21:24:03.207 回答