使用Java爲一個reducer輸出到另一個reducer的示例代碼片段代碼

Question

我是Hadoop和map-reduce程序的新手。如果有人回答我的問題將有幫助

我想寫一個mapreduce程序，其中將有兩個reducer。一個減速器的輸出給予另一個減速器。要有兩個減速器，應該有兩個作業驅動程序，有人可以給我提供一個示例代碼片段或任何mapreduce程序的示例代碼，其中一個減速器的輸出與作業的定義代碼一起提供給另一個reducer。

Answer 1

我們可以有兩個mapreduce作業。第一份工作的輸出可以作爲第二份工作的輸入。第二個工作的映射器可以只是一個標識映射器，它將輸入作爲輸出，我們可以爲第二個工作的縮減器創建邏輯。這兩個作業可以使用JobControl依次運行。