關於Spark裏面的RDD.mappartitions的問題

mappartitions的執行效率要比foreachpartitions高,可是對一個一樣的RDD,mappartitions裏面的call方法爲何不執行呢?這是懶加載的緣由,只有在使用mappartitions的結果的時候,它纔會真正去調用call方法執行,好比rdd.mappartitions.collect或者rdd.mappartitions.count
相關文章
相關標籤/搜索