mapreduce框架內部核心工作流程

mapreduce框架內部核心工作流程圖 流程 1、mapTask調用InputFormat再調用RecourReader的read()方法來讀取數據，獲得key、value，mapreduce通過InputFormat來解耦 2、read()方法依靠一次讀取一行的邏輯來讀取原始文件的數據，返回key、value，mapTask會將其交給自定義的Mapper 3、map方法我們會調用context

>>阅读原文<<