Hadoop LongSumReducer

Question

我正在使用 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>)

Answer 1

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