Wie führe ich das Zippen zwischen zwei DStreams in Scala durch?

Question

Ich habe zwei gefensterte dstreams, die ich gerne zippen würde wie das normale Zippen in RDDs.

Hinweis: Das Hauptziel ist es, den Mittelwert und die Standardabweichung des Fensters dstream zu berechnen, falls es eine bessere Möglichkeit gibt, dies zu berechnen.

Answer 1

Ich benutze DStreams transformWith, um diese rdd-Operation zu verwenden, und das löste mein Problem.

Beispiel:

valueStream.transformWith(mean, (rdd1: RDD[Int], rdd2 : RDD[Double]) => {rdd1.zip(rdd2)}