diff options
| author | Stephen Haberman <stephen@exigencecorp.com> | 2013-02-09 16:10:52 -0600 |
|---|---|---|
| committer | Stephen Haberman <stephen@exigencecorp.com> | 2013-02-09 16:10:52 -0600 |
| commit | fb7599870f4e3ee4e5a1e3c6e74ac2eaa2aaabf0 (patch) | |
| tree | 1b52c5adbaed45f6098cca596069215915f74c3a /core/src/main/scala | |
| parent | 2a18cd826c42d7c6b35eaedde1e4c423b6a1b1e5 (diff) | |
| download | spark-fb7599870f4e3ee4e5a1e3c6e74ac2eaa2aaabf0.tar.gz spark-fb7599870f4e3ee4e5a1e3c6e74ac2eaa2aaabf0.tar.bz2 spark-fb7599870f4e3ee4e5a1e3c6e74ac2eaa2aaabf0.zip | |
Fix JavaRDDLike.coalesce return type.
Diffstat (limited to 'core/src/main/scala')
| -rw-r--r-- | core/src/main/scala/spark/api/java/JavaRDDLike.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/api/java/JavaRDDLike.scala b/core/src/main/scala/spark/api/java/JavaRDDLike.scala index d3a4b62553..9e52c224dd 100644 --- a/core/src/main/scala/spark/api/java/JavaRDDLike.scala +++ b/core/src/main/scala/spark/api/java/JavaRDDLike.scala @@ -133,7 +133,7 @@ trait JavaRDDLike[T, This <: JavaRDDLike[T, This]] extends PairFlatMapWorkaround /** * Return a new RDD that is reduced into `numSplits` partitions. */ - def coalesce(numSplits: Int): RDD[T] = rdd.coalesce(numSplits) + def coalesce(numSplits: Int): JavaRDD[T] = rdd.coalesce(numSplits) /** * Return an RDD of grouped elements. Each group consists of a key and a sequence of elements |