diff options
author | Patrick Wendell <pwendell@gmail.com> | 2012-12-07 19:16:35 -0800 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2012-12-07 19:34:05 -0800 |
commit | 3e796bdd57297134ed40b20d7692cd9c8cd6efba (patch) | |
tree | f51b3f1c2ef11f3553f0c8ba131f9601eff9f2ff /core | |
parent | 3ff9710265d4bb518b89461cfb0fcc771e61a726 (diff) | |
download | spark-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.scala | 6 |
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) } |