Scala – 大小写操作(x,y)=> x y

发布时间：2020-12-16 09:51:23 所属栏目：安全来源：网络整理

导读：我是斯卡拉的新手.我正在阅读一个无法理解的代码.有人可以帮我理解下面的代码吗？ def intersectByKey[K: ClassTag,V: ClassTag](rdd1: RDD[(K,V)],rdd2: RDD[(K,V)]): RDD[(K,V)] = { rdd1.cogroup(rdd2).flatMapValues{ case (Nil,_) = None case (_,Nil)

我是斯卡拉的新手.我正在阅读一个无法理解的代码.有人可以帮我理解下面的代码吗？

def intersectByKey[K: ClassTag,V: ClassTag](rdd1: RDD[(K,V)],rdd2: RDD[(K,V)]): RDD[(K,V)] = {
    rdd1.cogroup(rdd2).flatMapValues{
      case (Nil,_) => None
      case (_,Nil) => None
      case (x,y) => x++y
    }
  }

下线是什么意思？如何评估？

case (x,y) => x++y

谢谢

解决方法

rdd1.cogroup(rdd2)返回RDD [(K,(Iterable [V],Iterable [V]))]类型的值. 所以 – 在情况(x,y)中,x和y都是可迭代的[V]. Iterable重载操作符,其实现只是表示union – 返回一个带有所有x值的迭代,后跟所有y的值.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!

Scala – 大小写操作(x,y)=&gt; x y

解决方法

Scala – 大小写操作(x,y)=> x y