2016-11-16 61 views
1

的CEP库使得如果X后跟Y.如何写一个弗林克CEP程序,事件的顺序并不重要

val pattern = Pattern.begin("start").where(_.value == "X") .next("end).where(_.value == "Y")

简单写一个程序来描述,它可以告诉但是,我将如何描述一个程序,我不关心X和Y的顺序,而只关心另一个顺序。例如X,Y和Y,X都很有意思。但是,X,X或Y,Y不是很有趣,所以我无法在第三个共享属性上匹配。

回答

1

目前,Flink的CEP库不支持此功能。你可以做的是分别定义这两个模式,然后在select子句后合并两个结果数据流。