开发者社区> 问答> 正文

CEP匹配乱序数据的问题

咨询一个问题,flink-training-exercises练习的工程里面

com.ververica.flinktraining.solutions.datastream_java.cep.LongRidesSolution

Pattern<TaxiRide, TaxiRide> completedRides =

Pattern. begin("start")

.where(new SimpleCondition () {

@Override

public boolean filter(TaxiRide ride) throws Exception {

return ride.isStart;

}

})

.next("end")

.where(new SimpleCondition () {

@Override

public boolean filter(TaxiRide ride) throws Exception {

return !ride.isStart;

}

});

现在有一个类似的监控场景,也是需要超时后输出没有匹配到的数据,但是流的数据有可能产生乱序。

是不是就不能匹配例子中的Pattern?

如果我想乱序的数据也要匹配上,不作为超时输出有什么对应的解决方案吗?

*来自志愿者整理的flink邮件归档

展开
收起
EXCEED 2021-12-08 12:04:19 488 0
1 条回答
写回答
取消 提交回答
  • CEP的 sql中order by , 不会因为乱序导致不匹配。

    在api中没用过,可以看看是否有对应的api*来自志愿者整理的flink邮件归档

    2021-12-08 13:57:57
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载