http://blog.csdn.net/bluishglc/article/details/9380087
相应地,在LineRecordReader判断是否还有下一行的方法:org.apache.hadoop.mapred.LineRecordReader.next(LongWritable, Text) 170到173行中,while使用的判定条件是:当前位置小于或等于split的结尾位置,也就说:当当前以处于split的结尾位置上时,while依然会执行一次,这一次读到显然已经是下一个split的开始行了!
学习该博客
TextInputFormat如何处理跨split的行
猜你喜欢
转载自wangqiaowqo.iteye.com/blog/2085285
今日推荐
周排行