hadoop - Hadoop Oozie MapReduce 操作自定义分区器

Question

如何在 oozie 工作流 XML 上为 MapReduce 操作配置自定义分区器？我尝试使用：

<property>
    <name>mapreduce.job.partitioner.class</name>
    <value>com.package.MyPartitioner</value>
</property>
<property>
    <name>mapreduce.partitioner.class</name>
    <value>com.package.MyPartitioner</value>
</property>

Answer 1

以下是为 mapreduce 新 api 指定分区器类的配置。

<property>
   <name>mapreduce.partitioner.class</name>
   <value>test.hadoop.apps.log.LogPartitioner</value>
</property>