Flink CEP 对超时事件的处理

今天在群里面有个同窗问了一个问题,一个通用场景,例如:用户2小时不评价订单,自动好评功能。web 这种多长时间内没有收到第二个事件的问题,想了下觉得能够用notFollowedBy 来解决,结果不行。 查了一下文档, 写了下面一个demo,记录一下,备忘socket final StreamExecutionEnvironment env = StreamExecutionEnvironment.
相关文章
相关标签/搜索