aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorPatrick Wendell <pwendell@gmail.com>2012-12-07 19:16:35 -0800
committerPatrick Wendell <pwendell@gmail.com>2012-12-07 19:34:05 -0800
commit3e796bdd57297134ed40b20d7692cd9c8cd6efba (patch)
treef51b3f1c2ef11f3553f0c8ba131f9601eff9f2ff /core
parent3ff9710265d4bb518b89461cfb0fcc771e61a726 (diff)
downloadspark-3e796bdd57297134ed40b20d7692cd9c8cd6efba.tar.gz
spark-3e796bdd57297134ed40b20d7692cd9c8cd6efba.tar.bz2
spark-3e796bdd57297134ed40b20d7692cd9c8cd6efba.zip
Changes in response to TD's review.
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/spark/SparkContext.scala6
1 files changed, 3 insertions, 3 deletions
diff --git a/core/src/main/scala/spark/SparkContext.scala b/core/src/main/scala/spark/SparkContext.scala
index 7ae1aea993..3ccdbfe10e 100644
--- a/core/src/main/scala/spark/SparkContext.scala
+++ b/core/src/main/scala/spark/SparkContext.scala
@@ -203,9 +203,9 @@ class SparkContext(
}
/** Distribute a local Scala collection to form an RDD, with one or more
- * location preferences for each object. Create a new partition for each
- * collection item. */
- def makeLocalityConstrainedRDD[T: ClassManifest](seq: Seq[(T, Seq[String])]): RDD[T] = {
+ * location preferences (hostnames of Spark nodes) for each object.
+ * Create a new partition for each collection item. */
+ def makeRDD[T: ClassManifest](seq: Seq[(T, Seq[String])]): RDD[T] = {
val indexToPrefs = seq.zipWithIndex.map(t => (t._2, t._1._2)).toMap
new ParallelCollection[T](this, seq.map(_._1), seq.size, indexToPrefs)
}