Hi Anton, I think embedding Drools into Flink should be doable. Drools seems to be implemented in Java, so you can probably call the engine from Flink. I would start putting a flatMap() operator into a stream. In the operator, I would start the Drools engine (probably in the open() method) and then give the individual records to the engine.
Regards, Robert On Tue, Jun 21, 2016 at 7:55 AM, Anton <kurren...@gmail.com> wrote: > Hello > > Firstly, I am an absolute Flink newbie. > > I am interested in using Drools in Flink - in a similar case to what is > described in this blog, where Drools is used in Spark. > > http://blog.cloudera.com/blog/2015/11/how-to-build-a-complex-event-processing-app-on-apache-spark-and-drools/ > > The basic idea is that Drools can be used to reason over streaming data. > > The high-level use case is, there are several hundred users who want to > write rules to be notified on events related to changes in specific > streams. For example, notify me when a specific stock price changes by so > much. > > Due to the number of users, the more end-user focused syntax of Drools, and > the number of rule changes, doing this in Drools makes more sense than to > write and deploy plain-old-flink (apologies, am not familiar with the > correct term for a flink process). > > Also, as Drools has some powerful CEP operators, it could be very > interested to have these available in Flink too. > > My question, therefore, is, very general - how best to integrate Drools > into Flink? Where should I start? > > Thanks and regards > Anton >
