前言
在日常开发中,经常涉及到对不同集合数据进行交集,并集和差集的操作,在Spark 中,也提供了类似的算子帮助我们处理这样的业务,即双 Value 类型 数据处理;
intersection
函数签名
def intersection(other: RDD[T]): RDD[T]
函数说明
对源 RDD 和参数 RDD 求交集后返回一个新的 RDD
案例一,求两个集合的交集
import org.apache.spa
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
文章由半码博客整理,本文链接:https://www.bmabk.com/index.php/post/143251.html