CEP匹配乱序数据的问题

Mon, 23 Dec 2019 05:38:23 -0800 

HI，大家好。

咨询一个问题，flink-training-exercises练习的工程里面
com.ververica.flinktraining.solutions.datastream_java.cep.LongRidesSolution

Pattern<TaxiRide, TaxiRide> completedRides =
Pattern.<TaxiRide>begin("start")
.where(new SimpleCondition<TaxiRide>() {
@Override
public boolean filter(TaxiRide ride) throws Exception {
return ride.isStart;
}
})
.next("end")
.where(new SimpleCondition<TaxiRide>() {
@Override
public boolean filter(TaxiRide ride) throws Exception {
return !ride.isStart;
}
});

现在有一个类似的监控场景，也是需要超时后输出没有匹配到的数据，但是流的数据有可能产生乱序。
是不是就不能匹配例子中的Pattern？
如果我想乱序的数据也要匹配上，不作为超时输出有什么对应的解决方案吗？

回复