什么时候在flink中使用协处理函数?

7hiiyaii  于 2021-06-24  发布在  Flink
关注(0)|答案(1)|浏览(288)

我只是想了解在flink中何时使用协处理函数的用例。举例说明有助于我更好地理解这个概念。

pftdvrlh

pftdvrlh1#

协处理函数类似于richcoflatmap,但是还可以使用计时器。例如,计时器对于过期键的过期状态很有用,或者在keep-alive消息无法到达时发出警报。
协处理函数允许您使用一个流来影响另一个流的处理方式,或者丰富另一个流。例如,一个电子商务站点可能有一个订单事件流和一个发货事件流,并且他们希望在下订单的24小时内为尚未发货的订单创建一个事件流。这两个流可以通过orderid设置密钥,并连接在一起。当订单到达时,它被记录在键控状态,并创建一个计时器,在24小时后触发。当装运事件到达时,状态和计时器被清除。如果计时器启动,则使用状态将订单发送到未完成订单服务。
有关这方面的更多信息以及代码示例,请参阅这些教程附带的连接流和流程函数以及实验室。

相关问题