hadoop - 为什么Reducer.class 不能在Hadoop MapReduce 中用作真正的reducer？

Question

我注意到 Mapper.class 可以用作阶段中的真正映射器，以及用户定义的 reducer 。例如，

Phase 1:
Mapper.class ->  WordCountReduce.class

这将起作用。
但是，Reducer.class 不能以相同的方式使用。即类似

Phase 2:
WordReadMap.class ->  Reducer.class

不管用。

这是为什么？

Answer 1

我不明白为什么只要输出与输入属于同一类，它就不会。 default in the new API只是写出你传递给它的任何东西，它被实现为

@SuppressWarnings("unchecked")
protected void reduce(KEYIN key, Iterable<VALUEIN> values, Context context
                       ) throws IOException, InterruptedException {
    for(VALUEIN value: values) {
      context.write((KEYOUT) key, (VALUEOUT) value);
    }
}

对于旧 API，它是 interface ，并且不能直接实例化接口(interface)。如果您正在使用它，那么这就是它失败的原因。再说一次， Mapper也是一个接口(interface)，你不应该实例化它......