function - Hadoop：在 2 个作业之间执行本地方法

Question

有没有办法在两个后续 MapReduce 作业之间的数据上执行（相对较短的）本地方法？

如果是，如何实现？

提前致谢！

Answer 1

一种简单的方法是：

1. 声明你的工作对象Job job1 = new Job(conf1);和Job job2 = new Job(conf2);
2. 为这些作业设置正确的映射器/缩减器和作业名称。

3. 在 Main 函数中，您可以执行以下操作：

   job1.waitForCompletion(true);
   //execute your local method
   method();
   job2.waitForCompletion(true);