如何从java运行mapreduceindexertool作业?

g0czyy6m  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(378)

我想从java运行mapreduceindexertool。
现在我在命令行中使用 hadoop jar 正如您在这里看到的,但是我想从java代码中检查它的状态(查看它是否已完成、正在进行等)。
所以基本上我想从java运行它,以便能够从java检查它的状态。有没有办法从命令行运行它并从java检查它的状态?
另外,还有一种方法可以使map reduce在作业完成时发送事件(例如在回调上)?像网钩一样的东西?

9udxz4iz

9udxz4iz1#

据我所知,工具接口只公开 int run(String[] args) 方法,所以通常您将创建新示例,形成适当的参数字符串并调用该方法。
另一方面,mapreduceindexertool具有 int run(Options options) 方法,该方法可用于运行它,而无需形成shell样式的参数。然而,这个方法是受保护的,所以这将需要在与之相同的包中创建调用类 MapReduceIndexerTool .

相关问题