首页 > TAG信息列表 > rightouterjoin
第五章_Spark核心编程_Rdd_转换算子_keyValue型_join&leftOuterJoin&rightOuterJoin&fullOuterJoin
1. join /* * 1.定义 * def join[W](other: RDD[(K, W)]): RDD[(K, (V, W))] * def join[W](other: RDD[(K, W)], numPartitions: Int): RDD[(K, (V, W))] * 2.功能 * 将两个 类型为(K,V)和(K,W)的RDD 进行join，返回一个相同 key 对应的所有元素连接在一Join，leftouterjoin,,rightouterjoin,fullouterjoin算子
join类型算子，是依赖于K,V类型的算子，是俩个RDD的交集操作，底层是cogroup算子+flatmapvalues算子操作。 leftouterjoin类型算子，是依赖于K,V类型的算子，是俩个RDD的交集操作，底层是cogroup算子+flatmapvalues算子操作。类似于mysql的左外连接 rightouterjoin类型算子，是依赖于K,V类型