scala中分组的算子的用法
2024-09-01 13:27:33
val rdd= sc.parallelize(List(("tom",1),("jerry",3),("kitty",2),("tom",2)))
//1.根据传入的参数进行分组
val rdd1:RDD[(String, Iterable[(String, Int)])] =rdd.groupBy(_._1)
println(rdd1.collect.toBuffer)
//2.根据key进行分区(对KV形式是使用) -->除了指定分组之后分区的数量之外, 还可以使用自定义分区器
val rdd2: RDD[(String, Iterable[Int])] = rdd.groupByKey()
println(rdd2.collect.toBuffer)
最新文章
- BeanFactory vs ApplicationContext
- Java中常量小知识
- 01Spring_基本jia包的导入andSpring的整体架构and怎么加入日志功能
- DDL, DML不是所有SQL都是可以自动回滚的
- 性能测试之-wrk(转)
- 基于asp.net的Web开发架构探索
- Lattice Diamond安装
- 简易的highcharts公共绘图模块封装--基于.net mvc
- ora-01445 无法从不带保留关键字的表的联接视图中选择 ROWID 或采样
- 通过ssh訪问NAT网络模式虚拟机里的Linux
- HDU-5340 Three Palindromes(字符串哈希)
- Java NIO FileVisitor 高效删除文件
- installshield安装包制作
- Python之字典方法
- 【Spring】SpringMVC配置文件
- addEventListener以及滑轮滑动事件的应用
- Struts2验证框架_xml验证失败
- vsphere和vmware快照的不足之处
- (五)ROS节点
- CentOS vps下,安装xfce/KDE/GNOME桌面+vncserver进行远程管理