Yinelemeli bir hesaplamanın sonuçlarını toplamak için bir RDD oluşturmak istiyorum.Yinelemeli bir hesaplamanın sonuçlarını toplamak için bir RDD oluşturma
import org.apache.spark.mllib.random.RandomRDDs._
val n = 10
val step1 = normalRDD(sc, n, seed = 1)
val step2 = normalRDD(sc, n, seed = (step1.max).toLong)
val result1 = step1.zip(step2)
val step3 = normalRDD(sc, n, seed = (step2.max).toLong)
val result2 = result1.zip(step3)
...
val step50 = normalRDD(sc, n, seed = (step49.max).toLong)
val result49 = result48.zip(step50)
(N, ara RDDs oluşturma ve sonunda birlikte daha sonra sıkıştırma aynı zamanda 50 RDDs uzun ok gibi olacaktır: Aşağıdaki kodunu değiştirmek için bir döngü (ya da herhangi bir alternatif) kullanabilir nasıl
tohum = saygı iteratif oluşturulur (adım (n-1) .max) durumu)
bir oluşturmak için scalaz gelen 'Stream.unfold' kullanmayı tercih ediyorum adımların akışı ve ardından sıkıştır Kendisi ve/veya scanRight ile .. – Reactormonk