首页 > 其他 > 详细

Hadoop源码---Inputformat

时间:2015-08-19 23:45:24      阅读:224      评论:0      收藏:0      [点我收藏+]

作用:

1、将输入切分成split,确定split大小,map个数。 由getSplits方法实现。

 2、为mapper提供输入数据,key/value形式。getRecordReader方法

核心算法:

1、文件切分算

作用:确定split个数。

概念:

 globalSize: totalsize/numSplits  ; 

minSize: InputSplit 最小值 配置参数

blockSize: block大小

公式: splitSize = max{ minSize, min{globalSize,blockSize}}


2、数据本地化(host选择)

目的是 减少数据传输,尽量将InputSplit存放在本地。

算法:对rack包含的数据量排序,对rack中节点排序,取top3


版权声明:本文为博主原创文章,未经博主允许不得转载。

Hadoop源码---Inputformat

原文:http://blog.csdn.net/smile0198/article/details/47789309

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!