1

我正在使用 hadoop "2.0.0-cdh4.1.1" 并尝试将其LongSumReducer用于我的 wordCount 程序。

job.setReducerClass((new LongSumReducer<Text>()).getClass());

但是有一个编译错误:

setReducerClass(java.lang.Class<? extends org.apache.hadoop.mapreduce.Reducer>) in
org.apache.hadoop.mapreduce.Job cannot be applied to (java.lang.Class<capture#402 of
extends org.apache.hadoop.mapred.lib.LongSumReducer>)
4

1 回答 1

0

它是实现正确的接口还是为reducer 实现扩展正确的类。异常表示所需的实现方法与使用方法的包差异(新与旧 hadoop api)

于 2012-11-19T21:21:25.553 回答