MapReduce工作流程詳解

MapReduce工作流程 1.由程序內的InputFormat(默認實現類TextInputFormat)來讀取外部數據，它會調用RecordReader(它的成員變量)的read()方法來讀取，返回k,v鍵值對。 2.讀取的k,v鍵值對傳送給map()方法，作爲其入參來執行用戶定義的map邏輯。 3.context.write方法被調用時，outputCollector組件會將map()方法的

>>阅读原文<<