Flink 什么时候使用 CoProcess Function？

Question

我只是想了解在 Flink 中使用 CoProcessFunction 的用例。举例说明可以帮助我更好地理解这个概念。

Answer 1

CoProcessFunction 类似于 RichCoFlatMap，但还可以使用计时器。例如，计时器可用于使陈旧密钥的状态过期，或在保持活动消息未能到达时发出警报。

CoProcessFunction 允许您使用一个流来影响另一个流的处理方式，或丰富另一个流。例如，电子商务网站可能有一个订单事件流和一个发货事件流，他们想要为下订单后 24 小时内未发货的订单创建一个事件流。这两个流可以通过 orderId 键控，并连接在一起。当订单到达时，它会被记录为键控状态，并创建一个计时器以在 24 小时后触发。当装运事件到达时，状态和计时器被清除。如果计时器确实触发，则该状态用于将订单发送到未完成的订单服务。

有关这方面的更多信息以及代码示例，请参阅 connected streams and process function 以及这些教程附带的实验。