MapTask运行机制详解

资料来源于网络   6、MapTask运行机制详解以及Map任务的并行度   整个Map阶段流程大体如上图所示。简单概述:inputFile通过split被逻辑切分为多个split文件,通过Record按行读取内容给map(用户自己实现的)进行处理,数据被map处理结束之后交给OutputCollector收集器,对其结果key进行分区(默认使用hash分区),然后写入buffer,每个map t
相关文章
相关标签/搜索