如何使用多个连接密钥连接两个流

Question

下面的代码片段是从JoinedStreams的javadoc复制的

val one: DataStream[(String, Int)]  = ...
val two: DataStream[(String, Int)] = ...

val result = one.join(two)
    .where {t => ... }
    .equal {t => ... }
    .window(TumblingEventTimeWindows.of(Time.of(5, TimeUnit.SECONDS)))
    .apply(new MyJoinFunction())

这两个流仅基于一个键(通过< code>t =计算)进行连接

我会问我如何基于多个键进行连接，例如，one.a = two.a和one.b = two.b

Answer 1

通过在连接时使用KeySelector，可以生成一个元组来表示两个键。

Answer 2

您的键选择器可以返回元组。，

.where {t => (t.a, t.b)}
.equals {t => (t.a, t.b)}