Re: Spark custom streaming receiver not storing data reliably?

2015-07-06 Thread Ajit Bhingarkar
c List getCustomersWithOffers() > { > return customersWithOffers; > } > } > > > On Mon, Jul 6, 2015 at 10:21 AM, Jörn Franke wrote: > >> Can you provide the result set you are using and specify how you >> integrated the drools engine? >> Drools

Re: Spark custom streaming receiver not storing data reliably?

2015-07-05 Thread Ajit Bhingarkar
emory. Hence, if you have > several tasks in Shark they end up using different shared memory areas. > A full integration of drools requires some sophisticated design and > probably rewriting of the rules evaluation algorithm, so you probably have > to rewrite that engine from scratch. >

Spark custom streaming receiver not storing data reliably?

2015-07-05 Thread Ajit Bhingarkar
Hi, I am trying to integrate Drools rules API with Spark so that the solution could solve few CEP centric use cases. When I read data from a local file (simple FileWriter -> readLine()), I see that all my rules are reliably fired and everytime I get the results as expected. I have tested with fil