java - 为什么 IdentityMapper 在 org.apache.hadoop.mapreduce 库中消失了？

Question

在旧版本的 hadoop 库(即 org.apache.hadoop.mapred.lib)中，有一个名为 IdentityMapper 的 Mapper 基本实现。 ，它基本上将所有键值对传递给 Reducer。

但是，我在较新版本的 hadoop 库 (org.apache.hadoop.mapreduce.lib) 中发现，它没有任何名为 IdentityMapper 的类(可以找到 Mapper 的所有子类 here ).

我能知道IdentityMapper在新库中是改名还是消失了吗？

如果答案是第二个，我能进一步知道为什么IdentityMapper会消失吗？这是否意味着我们可以在中间没有 Mapper 的情况下链接多个 Reducer 吗？

Answer 1

突然意识到设计...

简短的回答是:新的 Mapper 是旧的 IdentityMapper。

这是一个更长的答案:

在老图书馆，Mapper是一个接口(interface)，它的基本实现叫做IdentityMapper .

但是，在新库中，它不再具有映射器的基本接口(interface)。相反，它有一个名为 Mapper 的映射器公共(public)基类。 ，其实现是之前的IdentityMapper。