java - 迭代器不允许使用 reducer

Question

我试图在我的reducer中编写以下代码，并且编译错误出现如下:

The method collect(Text, Text) in the type OutputCollector<Text,Text> is not applicable for the arguments (Text, Iterator<Text>)

public void reduce(Text key, Iterator<Text> values, OutputCollector<Text, Text> output, Reporter reporter) throws IOException {            
   output.collect(key, values);
}

据我所知， map <K,V>的输出经过混洗和排序，形成了reducer输入的集合。

我能知道错误背后的原因吗？

Answer 1

错误消息发出的问题是OutputCollector<K,V>类的类型签名和collect(K,V)方法必须匹配。

在这种情况下，它们不匹配，因为您声明了

OutputCollector<Text, Text> output

但试图打电话

output.collect(key, values);

且 values的类型为 Iterator<Text>，与 OutputCollector<Text,Text>期望的值的值类型Text不匹配。