This may help you out. https://github.com/apache/flink/blob/master/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java
On Sun, Jan 17, 2021 at 10:32 AM narasimha <swamy.haj...@gmail.com> wrote: > > Hi, > > I'm using Flink CEP, but couldn't find any examples for writing test cases > for the streams with CEP. > > Can someone help on how to write test cases for streams with CEP applied on > it? > > -- > A.Narasimha Swamy -- Cheers, Aeden