spark建立一個空的RDD

現有需求要建立一個空的RDD不含任何元素和分區 首先想到的是: java val emptyRDD = sc.makeRDD(Array()) 但是這麼建立竟然會報錯!!! 而後想着本身寫個類繼承RDD抽象類，能夠實現。 不過這兩天發現竟然spark其實已經爲咱們寫好了EmptyRDD,源碼以下 apache package org.apache.spark.rdd import scala.r

>>阅读原文<<