spark RDD key/value关联操作
2015-10-17 21:48
316 查看
RDD key/value关联操作
val left = sc.parallelize(List(("spark",1),("hadoop",1),("storm",1)))
val left = sc.parallelize(List(("scala",1),("hadoop",1),("spark",1)))
关联2个RDD
val joinOut = left join right
left.join(right)
(left cogroup right).collect
val left = sc.parallelize(List(("spark",1),("hadoop",1),("storm",1)))
val left = sc.parallelize(List(("scala",1),("hadoop",1),("spark",1)))
关联2个RDD
val joinOut = left join right
res9: Array[(String, (Int, Int))] = Array((spark,(1,1)), (hadoop,(1,1)))
left.join(right)
(left cogroup right).collect
相关文章推荐
- 【IOS 开发学习总结-OC-53】★★ios开发UI 控件——UISearchBar与UISearchDisplayController
- 详细整理:UITableView优化技巧
- Advanced Fruits(合并字符串+最长公共子序列应用)hdu1503 +动态规划
- pcduino里,Qt无法打开摄像头(调用了opencv)
- Prime Query【ZOJ--3911】
- Common Subsequence(最长公共子序列+动态规划)hdu1159 经典
- Chapter 4 Divide-and-Conquer
- StoryBoard 关于Segue ----prepareForSegue:sender: 理解
- (转)探究requestDisallowInterceptTouchEvent失效的原因
- 【PAT】1017. Queueing at Bank (25)
- UI-设计模式 手势处理
- UI-事件处理
- storm 开发系列二 Clojue版本
- SPOJ GSS4 Can you answer these queries IV
- 提高Interface Builder高效工作的8个技巧
- CSU1661: Query Mutiple
- addTarget各个参数的含义:
- UI---UIImageView
- UI中横屏竖屏切换的一些方法(转)
- UI系统类继承树