Re: Integrating Flink CEP with a Rules Engine

2017-07-22 Thread Anton
We also have a requirement of using Drools in Flink. Drools brings a very mature and usable business rules editor. And to be able to integrate Drools into Flink would be very useful. On 23 June 2017 at 22:09, Suneel Marthi wrote: > Sorry I didn't read the whole thread. > >

Re: Integrating Flink CEP with a Rules Engine

2017-06-23 Thread Suneel Marthi
Sorry I didn't read the whole thread. We have a similar rqmt wherein the users would like to add/update/delete CEP patterns via UX or REST api and we started discussing building a REST api for that, glad to see that this is a common ask and if there's already a community effort around this -

Re: Integrating Flink CEP with a Rules Engine

2017-06-23 Thread Kostas Kloudas
The rules, or patterns supported by FlinkCEP are presented in the documentation link I posted earlier. Dynamically updating these patterns, is not supported yet, but there are discussions to add this feature soon. If the rules you need are supported by the current version of FlinkCEP, then

Re: Integrating Flink CEP with a Rules Engine

2017-06-23 Thread Sridhar Chellappa
Folks, Plenty of very good points but I see this discussion digressing from what I originally asked for. We need a dashboard to let the Business Analysts to define rules and the CEP to run them. My original question was how to solve this with Flink CEP? >From what I see, this is not a solved

Re: Integrating Flink CEP with a Rules Engine

2017-06-23 Thread Kostas Kloudas
Hi all, Currently there is an ongoing effort to integrate FlinkCEP with Flink's SQL API. There is already an open FLIP for this: https://cwiki.apache.org/confluence/display/FLINK/FLIP-20%3A+Integration+of+SQL+and+CEP

Re: Integrating Flink CEP with a Rules Engine

2017-06-23 Thread Suneel Marthi
FWIW, here's an old Cloudera blog about using Drools with Spark. https://blog.cloudera.com/blog/2015/11/how-to-build-a-complex-event-processing-app-on-apache-spark-and-drools/ It should be possible to invoke Drools from Flink in a similar way (I have not tried it). It all depends on what the

Re: Integrating Flink CEP with a Rules Engine

2017-06-23 Thread Ismaël Mejía
Hello, It is really interesting to see this discussion because that was one of the questions on the presentation on CEP at Berlin Buzzwords, and this is one line of work that may eventually make sense to explore. Rule engines like drools implement the Rete algorithm that if I understood

Re: Integrating Flink CEP with a Rules Engine

2017-06-23 Thread Kostas Kloudas
Hi Jorn and Sridhar, It would be worth describing a bit more what these tools are and what are your needs. In addition, and to see what the CEP library already offers here you can find the documentation: https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/libs/cep.html

Integrating Flink CEP with a Rules Engine

2017-06-23 Thread Sridhar Chellappa
Folks, I am new to Flink. One of the reasons why I am interested in Flink is because of its CEP library. Our CEP logic comprises of a set of complex business rules which will have to be managed (Create, Update, Delete) by a bunch of business analysts. Is there a way I can integrate other third