1

我有两个 DStream。让A:DStream[X]和B:DStream[Y]。

我想得到它们的笛卡尔积，换句话说，一个新C:DStream[(X, Y)] 的包含所有对X和Y值。

我知道 RDD 有一个cartesian功能。我只能找到这个类似的问题，但它是在 Java 中的，所以没有回答我的问题。

4

1 回答 1

1

链接问题的答案的 Scala 等价物（忽略Time v3，此处未使用）是

A.transformWith(B, (rddA: RDD[X], rddB: RDD[Y]) => rddA.cartesian(rddB))

或更短

A.transformWith(B, (_: RDD[X]).cartesian(_: RDD[Y]))
于 2016-07-18T12:24:29.170 回答