apache-spark - Scalaで2つのDStream間で圧縮を実行するには?

Question

RDD での通常の圧縮のように圧縮したい 2 つのウィンドウ化された dstream があります。

注 : 主な目的は、これを計算するためのより良い方法がある場合に備えて、ウィンドウ dstream の平均と stdv を計算することです。