From da52b16b38a5d6200ef2c6a3b7ba28ddf35a30f8 Mon Sep 17 00:00:00 2001
From: Stephen Haberman <stephen@exigencecorp.com>
Date: Sat, 9 Feb 2013 10:11:54 -0600
Subject: [PATCH] Remove RDD.coalesce default arguments.
---
core/src/main/scala/spark/RDD.scala | 3 +--
core/src/main/scala/spark/api/java/JavaRDDLike.scala | 5 -----
2 files changed, 1 insertion(+), 7 deletions(-)
diff --git a/core/src/main/scala/spark/RDD.scala b/core/src/main/scala/spark/RDD.scala
index 5f99591fd5..dea52eb5c6 100644
--- a/core/src/main/scala/spark/RDD.scala
+++ b/core/src/main/scala/spark/RDD.scala
@@ -235,8 +235,7 @@ abstract class RDD[T: ClassManifest](
/**
* Return a new RDD that is reduced into `numSplits` partitions.
*/
- def coalesce(numSplits: Int = sc.defaultParallelism): RDD[T] =
- new CoalescedRDD(this, numSplits)
+ def coalesce(numSplits: Int): RDD[T] = new CoalescedRDD(this, numSplits)
/**
* Return a sampled subset of this RDD.
diff --git a/core/src/main/scala/spark/api/java/JavaRDDLike.scala b/core/src/main/scala/spark/api/java/JavaRDDLike.scala
index 295eaa57c0..d3a4b62553 100644
--- a/core/src/main/scala/spark/api/java/JavaRDDLike.scala
+++ b/core/src/main/scala/spark/api/java/JavaRDDLike.scala
@@ -130,11 +130,6 @@ trait JavaRDDLike[T, This <: JavaRDDLike[T, This]] extends PairFlatMapWorkaround
JavaPairRDD.fromRDD(rdd.cartesian(other.rdd)(other.classManifest))(classManifest,
other.classManifest)
- /**
- * Return a new RDD that is reduced into the default number of partitions.
- */
- def coalesce(): RDD[T] = coalesce(rdd.context.defaultParallelism)
-
/**
* Return a new RDD that is reduced into `numSplits` partitions.
*/
--
GitLab