Option是为了避免返回空值而设置的;
Spark Join的返回值类型是 RDD[(K, (V, Option[W]))],获取value时,需要用get函数
def leftOuterJoin[W](other: RDD[(K, W)]): RDD[(K, (V, Option[W]))]def leftOuterJoin[W](other: RDD[(K, W)], numPartitions: Int): RDD[(K, (V, Option[W]))]def leftOuterJoin[W](other: RDD[(K, W)], partitioner: Partitioner): RDD[(K, (V, Option[W]))]para1.leftoutjoin(para2).map(r=>{case (a,(b,c))=>{}if(c.getOrElse!="")a+"\t"+b+" "+c.getelsea+"\t"+b})
参考:
1、Option-https://www.twle.cn/l/yufei/scala/scala-basic-options.html
2、Spark Join算子-http://lxw1234.com/archives/2015/07/386.htm
