Re: 请教flink cep如何对无序数据处理

2021-05-21 文章 yue ma
这样可以嘛 > Pattern pattern = Pattern.begin("start").where(new > SimpleCondition() { >@Override >public boolean filter(Event value) throws Exception { > return value.getName().equals("a") || value.getName().equals("b"); >} > }).next("next").where(new IterativeCondition() { >

回复: 请教flink cep如何对无序数据处理

2021-05-15 文章 sherlock zw
老哥,这个图片好像我这边好像显示不出来。能否再重新发一次 发件人: Peihui He<mailto:peihu...@gmail.com> 发送时间: 2021年5月14日 19:55 收件人: user-zh@flink.apache.org<mailto:user-zh@flink.apache.org> 主题: Re: 请教flink cep如何对无序数据处理 [cid:ii_koo9jn4u1] 这样可以不? sherlock zw mailto:zw30...@live.com>> 于2021年5月14日周五 上午8:52写道: 兄

Re: 请教flink cep如何对无序数据处理

2021-05-14 文章 Peihui He
[image: image.png] 这样可以不? sherlock zw 于2021年5月14日周五 上午8:52写道: > 兄弟们,想问下Flink的CEP能够对无序数据流进行处理匹配嘛? > 我这里指的无序事件是:例如有两个事件,事件A和事件B,在一个时间窗口内,只要匹配到了A和B,不论A和B的到来顺序,我都认为是符合我的条件 >

请教flink cep如何对无序数据处理

2021-05-13 文章 sherlock zw
兄弟们,想问下Flink的CEP能够对无序数据流进行处理匹配嘛? 我这里指的无序事件是:例如有两个事件,事件A和事件B,在一个时间窗口内,只要匹配到了A和B,不论A和B的到来顺序,我都认为是符合我的条件