1
我的映射函數爲同一數據發出兩種不同類型的鍵值對。當然,我需要2個獨立的reduce函數來處理這個問題。可能嗎?映射後的多個(獨立)減少函數
像,我可以在地圖的末尾有多個output.collect()語句,並使用指定reducer的附加參數嗎? 我試圖查找它,但找不到任何東西。
我的映射函數爲同一數據發出兩種不同類型的鍵值對。當然,我需要2個獨立的reduce函數來處理這個問題。可能嗎?映射後的多個(獨立)減少函數
像,我可以在地圖的末尾有多個output.collect()語句,並使用指定reducer的附加參數嗎? 我試圖查找它,但找不到任何東西。
您應該考慮使用MultipleOutputs類。它有很好的和自我解釋的文檔。