diff options
| author | ryanlecompte <lecompte@gmail.com> | 2013-06-13 16:23:15 -0700 |
|---|---|---|
| committer | ryanlecompte <lecompte@gmail.com> | 2013-06-13 16:23:15 -0700 |
| commit | 44b8dbaedeb88f12ea911968c524883805f7ad95 (patch) | |
| tree | 935fe73ac25f86c8dca7288cfe216f08b1d88268 | |
| parent | db5bca08ff00565732946a9c0a0244a9f7021d82 (diff) | |
| download | spark-44b8dbaedeb88f12ea911968c524883805f7ad95.tar.gz spark-44b8dbaedeb88f12ea911968c524883805f7ad95.tar.bz2 spark-44b8dbaedeb88f12ea911968c524883805f7ad95.zip | |
use Iterator.single(elem) instead of Iterator(elem) for improved performance based on scaladocs
| -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 ec5e5e2433..bc9c17d507 100644 --- a/core/src/main/scala/spark/RDD.scala +++ b/core/src/main/scala/spark/RDD.scala @@ -734,7 +734,7 @@ abstract class RDD[T: ClassManifest]( val topK = mapPartitions { items => val queue = new BoundedPriorityQueue[T](num) queue ++= items - Iterator(queue) + Iterator.single(queue) }.reduce { (queue1, queue2) => queue1 ++= queue2 queue1 |