spark建立一个空的RDD

现有需求要建立一个空的RDD不含任何元素和分区 首先想到的是: java val emptyRDD = sc.makeRDD(Array()) 但是这么建立竟然会报错!!! 而后想着本身写个类继承RDD抽象类，能够实现。 不过这两天发现竟然spark其实已经为咱们写好了EmptyRDD,源码以下 apache package org.apache.spark.rdd import scala.r

>>阅读原文<<