Could you not do separate followedBy and then perform a join on the
resulting alert stream.
Pattern p1= followedBy(/*1st*/)
Pattern p2= followedBy(/*1st*/)
DataStream alertStream1 = CEP.pattern(keyedDs, p1)
DataStream alertStream2 = CEP.pattern(keyedDs, p2)
Then just join the two alertStream's
Hi all,
here's what I want to do: Consider a query such as *(A and B) followed_by
(C or D)*. (Pseudo code, obviously.) I want to create a graph of
independent processing nodes, each running an independent instance of
FlinkCEP. I want each of them to represent an operator of the query above,
like s
