diff options
| author | Stephen Haberman <stephen@exigencecorp.com> | 2013-03-22 12:59:08 -0500 |
|---|---|---|
| committer | Stephen Haberman <stephen@exigencecorp.com> | 2013-03-22 12:59:08 -0500 |
| commit | 00170eb0b9c30c1ab4f470c694b434385b8cbb7a (patch) | |
| tree | e615609402da2c649be8d853ed436904a1ae0974 /core | |
| parent | 1c67c7dfd1660dd39226742eedcb2948ab1445d0 (diff) | |
| download | spark-00170eb0b9c30c1ab4f470c694b434385b8cbb7a.tar.gz spark-00170eb0b9c30c1ab4f470c694b434385b8cbb7a.tar.bz2 spark-00170eb0b9c30c1ab4f470c694b434385b8cbb7a.zip | |
Fix are/our typo.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/RDD.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/RDD.scala b/core/src/main/scala/spark/RDD.scala index 0cd904f89d..b88d711dcf 100644 --- a/core/src/main/scala/spark/RDD.scala +++ b/core/src/main/scala/spark/RDD.scala @@ -240,7 +240,7 @@ abstract class RDD[T: ClassManifest]( */ def coalesce(numPartitions: Int, shuffle: Boolean = false): RDD[T] = { if (shuffle) { - // include a shuffle step so that are upstream tasks are still distributed + // include a shuffle step so that our upstream tasks are still distributed new CoalescedRDD(new ShuffledRDD(map(x => (x, null)), new HashPartitioner(numPartitions)), numPartitions).keys } else { new CoalescedRDD(this, numPartitions) |