Java：使用迭代器复制集合

Question

我有一个方法，它作为参数有一个集合的迭代器。在方法内部，我想复制迭代器“指向”的集合。 然而，只有最后一个集合条目出现在集合副本中，它出现了 N 次，其中 N 是原始集合的大小。

public void someMethod(Iterator<Node> values) {
  Vector<Node> centralNodeNeighbourhood = new Vector<Node>();
  while (values.hasNext()) {
    Node tmp = values.next();
    centralNodeNeighbourhood.add(tmp);
  }
  ...
  //store the centralNodeNeighbourhood on disk
}

示例“原始集合”：

1
2
3

示例“centralNodeNeighbourhood 集合”：

3
3
3

有人可以指出我的错误吗？我无法更改方法参数，我只能将迭代器获取到集合，对此无能为力。

更新（回答一些问题）

while (values.hasNext()) {
            Node tmp = values.next();
            System.out.print("Adding = "+tmp.toString());
            centralNodeNeighbourhood.add(tmp);
        }

打印正确的原始集合元素。 我不知道原始集合是什么类型，但 Iterator 来自 std java。该方法是

public class GatherNodeNeighboursInfoReducer extends MapReduceBase
        implements Reducer<IntWritable, Node, NullWritable, NodeNeighbourhood>{
    public void reduce(IntWritable key, Iterator<Node> values,
                   OutputCollector<NullWritable, NodeNeighbourhood> output, Reporter reporter) throws IOException {...}
}

旧Hadoop api（Hadoop版本0.20.203.0）中的方法

已解决 我在每次迭代时创建了 tmp 对象的副本，并将该副本添加到centralNodeNeighbourhood 集合中。这解决了我的问题。感谢您的所有（快速）帮助。

Answer 1

看起来迭代器每次都返回相同的 Node 对象。如果是这样，您需要在将节点添加到集合之前获取该节点的副本。 （否则您每次都会添加相同的对象，并且它将具有最后设置的值）

Answer 2

Hadoop 的 reduce 方法指定它重用其迭代器中的值对象。这是一件可怕的事情，但事实就是如此。

框架将重用传递到reduce中的键和值对象，因此应用程序应该克隆他们想要保留副本的对象。在许多情况下，所有值都组合成零或一个值。