我有一个应用程序,我想让我的 reducer(我有几个用于 map/reduce 作业)根据要处理的密钥将它们的输出记录到 HDFS 上的不同文件中。因此,如果reducer 看到A 类型的键,应用reduce 逻辑但告诉Hadoop 将结果放入属于A 类型结果的hdfs 文件中,依此类推。显然,多个reducer可以输出A类型结果的不同部分,每个reducer最终可以处理任何类型,如A或B,但告诉hadoop将结果写入A类型存储桶或其他东西
这可能吗?
我有一个应用程序,我想让我的 reducer(我有几个用于 map/reduce 作业)根据要处理的密钥将它们的输出记录到 HDFS 上的不同文件中。因此,如果reducer 看到A 类型的键,应用reduce 逻辑但告诉Hadoop 将结果放入属于A 类型结果的hdfs 文件中,依此类推。显然,多个reducer可以输出A类型结果的不同部分,每个reducer最终可以处理任何类型,如A或B,但告诉hadoop将结果写入A类型存储桶或其他东西
这可能吗?