This commit is contained in:
Mark Hamstra 2013-03-10 22:43:08 -07:00
Родитель 1289e7176b
Коммит 562893bea3
1 изменённых файлов: 2 добавлений и 2 удалений

Просмотреть файл

@ -204,9 +204,9 @@ class RDDSuite extends FunSuite with LocalSparkContext {
val ones = sc.makeRDD(Array(1, 1, 1, 1, 1, 1), 2) val ones = sc.makeRDD(Array(1, 1, 1, 1, 1, 1), 2)
val randoms = ones.flatMapWith( val randoms = ones.flatMapWith(
(index: Int) => new Random(index + 42)) (index: Int) => new Random(index + 42))
{(prng: Random, t: Int) => { {(prng: Random, t: Int) =>
val random = prng.nextDouble() val random = prng.nextDouble()
Seq(random * t, random * t * 10)}}. Seq(random * t, random * t * 10)}.
collect() collect()
val prn42_3 = { val prn42_3 = {
val prng42 = new Random(42) val prng42 = new Random(42)