MapReducer源碼解析

MapReducer源碼解析(筆記)   第一步,讀取數據源,將每一行內容解析成一個個鍵值對,每個鍵值對供map函數定義一次,數據源由FileInputFormat:指定的,程序就能從地址讀取記錄,讀取的記錄每一行內容是如何轉換成一個個鍵值對?Mapper函數是如何調用鍵值對?這是由InputFormatClass完成的,它在我們的例子中的具體實現類是TextInputFormat(Text是普通
相關文章
相關標籤/搜索