Как выполнить zip между двумя DStreams в Scala?

Question

У меня есть два оконных потока, которые я хотел бы заархивировать, как обычная застежка в RDD.

Примечание: Основная цель состоит в вычислении среднего значения и stdv окна dstream в случае, если есть лучший способ рассчитать это.

Answer 1

Я использовал преобразование DStream для использования этой операции rdd, и это решило мою проблему.

Пример:

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