我有一个案例，我使用 Hadoop 来监听/接收来自 JMS 队列的消息。如果队列有消息则触发 map/reduce 程序，所以我们不希望 map reduce 死掉，我们需要循环多次执行 map/reduce 代码。
我的问题是：
public boolean nextKeyValue() throws IOException使用这种方法，我们每次都返回键和值。如果我返回 false，则 map reduce 代码将运行到完成。如果我返回 true，map/reduce 代码将等待下一个键值，而不是调用 reduce 方法。那么有什么方法可以在 map 方法之后运行 reduce 方法，并且 nextKeyValue 返回 true 以等待 JMS 队列下一条消息？或者任何人对 Hadoop 读取继续数据源有好的想法，然后并行执行映射/减少，与 Hstreaming 相同的功能？