map()和reduce()应该返回相同类型的键/值对吗?

不,显然,map的输出对和reduce的输入对的类型必须相同,因为其中一个被传递给另一个。

但是,很有可能您有一个reduce任务,它输出的类型与传入的map对不同-例如,如果map任务计算文档中的单词,而reduce任务计算的是平均单词频率。在这种情况下,map将发出整数,而reduce将发出浮点数。

映射和减少输出可能不同。但是您需要告诉应用程序它们是。方法如下:

setOutputKeyClass()和setOutputValueClass()方法控制映射和reduce函数的输出类型,这些类型通常是相同的。

如果它们不同,可以分别通过setMapOutputKeyClass()和setMapOutputValue设置映射输出键/值类型。