Hi, I'm not familiar with the other library that you have mentioned, and indeed using Flink CEP from within a stateful function is not possible within a single Flink job, as Gordon mentioned.
I'm wondering what aspects of CEP are you interested in? Because essentially a stateful function can be considered as a state machine with auxiliary state. You can take a look at the ride sharing example [1] for instance, where the drivers, and the rides are cooperative state machines. [1] - https://github.com/apache/flink-statefun/tree/master/statefun-examples/statefun-ridesharing-example/statefun-ridesharing-example-functions/src/main/java/org/apache/flink/statefun/examples/ridesharing Good luck! Igal. On Tue, Apr 14, 2020 at 5:07 AM Tzu-Li (Gordon) Tai <tzuli...@apache.org> wrote: > Hi! > > It isn't possible to use Flink CEP within Stateful Functions. > > That could be an interesting primitive, to add CEP-based function > constructs. > Could your briefly describe what you are trying to achieve? > > On the other hand, there are plans to integrate Stateful Functions more > closely with the Flink APIs. > One direction we've been thinking about is to, for example, support Flink > DataStreams as StateFun ingress / egresses. In this case, you'll be able to > use Flink CEP to detect patterns, and use the results as an ingress which > invokes functions within a StateFun app. > > Cheers, > Gordon > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
