首页 > 其他 > 详细

MapReduce之InputFormat和OutFormat

时间:2014-05-21 19:21:25      阅读:296      评论:0      收藏:0      [点我收藏+]

InputFormat中的Splits集合的获取;

InputFormat是一个接口,该接口有2个成员函数;

InputSplit[] getSplits(JobConf job, int numSplits) throws IOException;

RecordReader<K, V> getRecordReader(InputSplit split, JobConf job, Reporter reporter) throws IOException;

而FileInputFormat是继承了InputFormat接口的类,故而它需要实现这两个函数;

对于第一个函数实现:

 

 

 

 

 

 

 

 

 

 

 

 

MapReduce之InputFormat和OutFormat,布布扣,bubuko.com

MapReduce之InputFormat和OutFormat

原文:http://www.cnblogs.com/miner007/p/3740103.html

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