Changes to UnionRDD and EmptyRDD

pwendell · pwendell · commit 7fb13b21864a · 2014-04-06T10:35:57.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/rdd/EmptyRDD.scala b/core/src/main/scala/org/apache/spark/rdd/EmptyRDD.scala
@@ -24,7 +24,7 @@ import org.apache.spark.{Partition, SparkContext, TaskContext}
 /**
  * An RDD that has no partitions and no elements.
  */
-class EmptyRDD[T: ClassTag](sc: SparkContext) extends RDD[T](sc, Nil) {
+private[spark] class EmptyRDD[T: ClassTag](sc: SparkContext) extends RDD[T](sc, Nil) {
 
   override def getPartitions: Array[Partition] = Array.empty
 
diff --git a/core/src/main/scala/org/apache/spark/rdd/UnionRDD.scala b/core/src/main/scala/org/apache/spark/rdd/UnionRDD.scala
@@ -43,6 +43,7 @@ private[spark] class UnionPartition[T: ClassTag](idx: Int, rdd: RDD[T], splitInd
   }
 }
 
+/** <span class="badge" style="float: right; background-color: #44751E;">DEVELOPER API</span> */
 class UnionRDD[T: ClassTag](
     sc: SparkContext,
     @transient var rdds: Seq[RDD[T]])

Original file line number	Diff line number	Diff line change
`@@ -43,6 +43,7 @@ private[spark] class UnionPartition[T: ClassTag](idx: Int, rdd: RDD[T], splitInd`
`43`	`43`	`}`
`44`	`44`	`}`
`45`	`45`
	`46`	`+/** <span class="badge" style="float: right; background-color: #44751E;">DEVELOPER API</span> */`
`46`	`47`	`class UnionRDD[T: ClassTag](`
`47`	`48`	`sc: SparkContext,`
`48`	`49`	`@transient var rdds: Seq[RDD[T]])`