修改分区就行了
val rdd1 = sc.parallelize(Array(1,2,3,4,5,6,7,8))
#  查看分区数
rdd1.partitions.length
# 改成1个分区
val rdd2 = rdd1.repartition(1)
rdd2.partitions.length

最新文章

1. Eclipse Java注释模板设置详解
2. iOS工作笔记(十五)
3. 关于PHP的curl开启问题
4. threadlocal类
5. oracle系列--第一篇 数据库基础
6. laravel-v4.0.9
7. UNICODE字符集(20140520)
8. C语言sizeof陷阱
9. [转]Asp.net三种事务处理
10. Miller_Rabin (米勒-拉宾) 素性测试
11. NGUI系列教程五（角色信息跟随）
12. asp.net 如何改变GridView搜索出来关键字的颜色？就像百度似的，我获得的是一个集合，改变集合中关键字的集合
13. google base库中的WaitableEvent
14. Varnish 4.0
15. http & json
16. [leetcode-526-Beautiful Arrangement]
17. How It Works: CMemThread and Debugging Them
18. React从入门到放弃之前奏(2)：React简介
19. sublime和vscode 格式化Json ——两步走
20. [Day15]常用API(Object类、String类)

热门文章

1. 使用线性回归识别sklearn中的手写数字digit
2. JAVA-JSP内置对象之out对象
3. [转]Spring MVC 教程,快速入门,深入分析
4. hive INSERT OVERWRITE table could not be cleaned up.
5. u-boot2011.09 启动流程记录
6. jmap查看内存使用情况与生成heapdump
7. 在Ubuntu 14.04 64bit上安装网易云音乐Linux版本(最新官方版)
8. RMySQL数据库编程指南
9. Sword STL容器分类介绍
10. SAP ML 物料分类账详解（含取消激活物料帐方法）