- 链接地址:https://blog.csdn.net/weixin_30908941/article/details/99573028
- 链接标题:Spark算子讲解(一)-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:915
文章浏览阅读116次。1:Zip算子def zip[U](other: RDD[U])(implicit arg0: ClassTag[U]): RDD[(T, U)]将两个RDD做zip操作,如果当两个RDD分区数目不一样的话或每一个分区数目不一样的话则会异常。例如:val rdd1 = sc.parallelize(Array(1,2,3,4,5,6),2)val rdd2 = sc..._spark 的 toiterator的用处
版权声明:本文发布于特牛网址导航 内容均来源于互联网 如有侵权联系删除