Hi, you can also take a look at this: https://techblog.king.com/rbea-scalable-real-time-analytics-king/. From a high level it seems Drools implements something similar to the system that they developed on top of Flink.
Cheers, Aljoscha On Tue, 21 Jun 2016 at 12:04 Robert Metzger <rmetz...@apache.org> wrote: > 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 > > >
