我正在使用 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>)
最佳答案
它是否实现了正确的接口(interface)或为 reducer 实现扩展了正确的类。异常表示所需的实现方法与用法(新旧 hadoop api)的包差异
关于Hadoop LongSumReducer,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/13462432/