如何将减少输出文件的输出重命名为分区编号

Question

我在使用分区编号命名每个减少任务的输出文件时遇到了一些问题。我如何命名带有该分区号的输出文件？ 我看过MultipleTextOutputFormat。它可以用每个键的我选择的名称生成一个新文件。但是我想用我选择的名字命名每个分区的输出文件，即使用分区号。 请在这方面帮助我。

感谢

Answer 1

您可能需要继承OUTPUTFORMAT类并重写一些方法在其实现的解决方案。

Answer 2

也许你可以试试jobConf.getInt("mapred.task.partition", 0)在你的减速机中。