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.
>
>
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 -
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
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
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
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
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
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
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