java - 如何从 Java 运行 MapReduceIndexerTool 作业？

Question

我想从 Java 运行 MapReduceIndexerTool。

现在我使用 hadoop jar 从命令行执行此操作，如您所见 here ，但我想从 Java 代码检查它的状态(查看它是否已完成、正在进行等)。

所以基本上我想从 Java 运行它，以便能够从 Java 检查它的状态。有没有办法从命令行运行它并从 Java 检查它的状态？

此外，还有一种方法可以让 Map Reduce 在作业完成时发送一个事件(例如在回调上)？像 webhook 之类的东西？

Answer 1

据我所知，Tool 接口(interface)仅公开了 int run(String[] args) 方法，因此通常您会创建新实例，形成适当的参数字符串并调用该方法。

另一方面，MapReduceIndexerTool具有 int run(Options options) 方法，可用于在不形成 shell 样式参数的情况下运行它。但是，此方法是 protected ，因此需要在与 MapReduceIndexerTool 相同的包中创建调用类。