Spark API編程動手實戰-04-以在Spark 1.2版本實現對union、groupByKey、join、reduce、lookup等操作實踐...

下面看下union的使用: 使用collect操作查看一下執行結果: 再看下groupByKey的使用: 執行結果:   join操作就是一個笛卡爾積操作的過程,如下示例:   對rdd3和rdd4執行join操作:   使用collect查看執行結果: 可以看出join操作完全就是一個笛卡爾積的操作; reduce本身在RDD操作中屬於一個action類型的操作,會導致job的提交和執行: 下面
相關文章
相關標籤/搜索