Spark RDD在saveAsTextFile时直接保存成一个txt文件

时间:2015-07-09 11:07:05   收藏:0   阅读:721
在该语句之前加上repartition(1),即写作以下形式:
rdd.repartition(1).saveAsTextFile("out.txt")
即,之前每个partition保存成一个txt文件,现repartition成一个分区,然后再保存。
 
注意(未验证):这个操作对于大文件来说,repartition(1)可能会导致某一个节点内存不足,超出的部分会临时存放在硬盘中,影响saveAsTextFile存储速度。

原文:http://www.cnblogs.com/kevingu/p/4632351.html

评论(0
© 2014 bubuko.com 版权所有 - 联系我们:wmxa8@hotmail.com
打开技术之扣,分享程序人生!