Как объединить два потока с более чем одним ключом соединения

Question

Следующий фрагмент кода скопирован из javadoc JoinedStreams

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())

Два потока объединяются на основе только одного ключа (вычисляется с помощью t => ...), например, one.a = two.a,

Я бы спросил, как я могу выполнить объединение на основе более чем одного ключа, например, one.a = two.a и one.b = two.b

Answer 1

Ваши ключевые селекторы могут возвращать кортеж, т. Е.

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

Answer 2

Используя KeySelector при соединении, вы можете создать кортеж для представления двух ключей.