MapReduce工作機制詳解(MapTask和ReduceTask)

MapTask: 1.maptask0負責切片0 ,maptask1負責切片1,maptask2負責切片2。 2.maptask0通過一個組件TextinputFormat讀切片0,這個組件封裝一個LineRecordReader,裏面有next方法,每調一次方法從切片0裏讀一行,給maptask返回k1:行起始offset和value1:行內容。 3.調用mapper裏的map(k1,v1,co
相關文章
相關標籤/搜索