Hadoop を使用して JMS キューからメッセージをリッスン/受信する場合があります。キューにメッセージがある場合は、マップ/リデュース プログラムをトリガーするため、マップ リデュース ダイを使用したくない場合は、マップ/リデュース コードを何度もループ実行する必要があります。
私の問題は次のとおりです。
public boolean nextKeyValue() throws IOExceptionこのメソッドを使用して、毎回キーと値を返します。false を返すと、map reduce コードが実行されて終了します。true を返すと、map/reduce コードは reduce メソッドを呼び出すのではなく、次のキー値を待ちます。map メソッドの後に reduce メソッドをすぐに実行し、nextKeyValue が true を返し、JMS キューの次のメッセージを待機する方法はありますか?または、Hadoop の読み取り継続データソースについて、Hstreaming と同じ機能である map/reduce を並行して実行するための良いアイデアを誰かが持っていますか?