why not put the two pipelines together.
David Anderson 于2022年5月11日周三 00:13写道：
>
> This sounds like it might be a use case for something like a
> KeyedCoProcessFunction (or possibly a KeyedBroadcastProcessFunction,
> depending on the details). These operators can receive inputs from two
> diffe
This sounds like it might be a use case for something like a
KeyedCoProcessFunction (or possibly a KeyedBroadcastProcessFunction,
depending on the details). These operators can receive inputs from two
different sources, and share state between them.
The rides and fares exercise [1] from the flink-
