We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ff5a0a6 commit 940245eCopy full SHA for 940245e
core/src/main/scala/org/apache/spark/SparkContext.scala
@@ -972,7 +972,7 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli
972
973
/** Build the union of a list of RDDs passed as variable-length arguments. */
974
def union[T: ClassTag](first: RDD[T], rest: RDD[T]*): RDD[T] =
975
- new UnionRDD(this, Seq(first) ++ rest)
+ union(Seq(first) ++ rest)
976
977
/** Get an RDD that has no partitions or elements. */
978
def emptyRDD[T: ClassTag] = new EmptyRDD[T](this)
0 commit comments