我想从java运行mapreduceindexertool。现在我在命令行中使用 hadoop jar 正如您在这里看到的,但是我想从java代码中检查它的状态(查看它是否已完成、正在进行等)。所以基本上我想从java运行它,以便能够从java检查它的状态。有没有办法从命令行运行它并从java检查它的状态?另外,还有一种方法可以使map reduce在作业完成时发送事件(例如在回调上)?像网钩一样的东西?
hadoop jar
9udxz4iz1#
据我所知,工具接口只公开 int run(String[] args) 方法,所以通常您将创建新示例,形成适当的参数字符串并调用该方法。另一方面,mapreduceindexertool具有 int run(Options options) 方法,该方法可用于运行它,而无需形成shell样式的参数。然而,这个方法是受保护的,所以这将需要在与之相同的包中创建调用类 MapReduceIndexerTool .
int run(String[] args)
int run(Options options)
MapReduceIndexerTool
1条答案
按热度按时间9udxz4iz1#
据我所知,工具接口只公开
int run(String[] args)
方法,所以通常您将创建新示例,形成适当的参数字符串并调用该方法。另一方面,mapreduceindexertool具有
int run(Options options)
方法,该方法可用于运行它,而无需形成shell样式的参数。然而,这个方法是受保护的,所以这将需要在与之相同的包中创建调用类MapReduceIndexerTool
.