Option是为了避免返回空值而设置的;
    Spark Join的返回值类型是 RDD[(K, (V, Option[W]))],获取value时,需要用get函数

    1. def leftOuterJoin[W](other: RDD[(K, W)]): RDD[(K, (V, Option[W]))]
    2. def leftOuterJoin[W](other: RDD[(K, W)], numPartitions: Int): RDD[(K, (V, Option[W]))]
    3. def leftOuterJoin[W](other: RDD[(K, W)], partitioner: Partitioner): RDD[(K, (V, Option[W]))]
    4. para1.leftoutjoin(para2).map(r=>{
    5. case (a,(b,c))=>{}
    6. if(c.getOrElse!="")
    7. a+"\t"+b+" "+c.get
    8. else
    9. a+"\t"+b
    10. }
    11. )

    参考:
    1、Option-https://www.twle.cn/l/yufei/scala/scala-basic-options.html
    2、Spark Join算子-http://lxw1234.com/archives/2015/07/386.htm