我有两个流。它们都是超过 1 小时窗口的聚合数据。我想压缩这些流,以便将同一时间跨度上的聚合元组在一起,如果现在存在这样的对应匹配,则可能具有空值。
DataStream<OneHourAggA> one =
sourceA
.keyBy(d -> (String) d.values.get("m"))
.timeWindow(Time.hours(1))
.apply(new WorkWindwFolder());
DataSteam<OneHourAggB> other =
sourceB
.keyBy(d -> (String) d.values.get("m"))
.timeWindow(Time.hours(1))
.apply(new WorkWindwFolder());
DataStream<Tuple2<Option<OneHourAggA>,Option<OneHourAggB>> zipped =
sourceA.???(sourceB)
我怎样才能做到这一点?