Re: Optimizing multiple aggregate queries on a CEP using Flink

Thank you Kostas for your inputs. We will try to integrate an optimizer into flink and will get back in case we get stuck. Regards. On Thu, 15 Feb 2018 at 19:11 Kostas Kloudas wrote: > Hi Sahil, > > Currently CEP does not support multi-query optimizations

Re: Optimizing multiple aggregate queries on a CEP using Flink

Hi Sahil, Currently CEP does not support multi-query optimizations out-of-the-box. In some cases you can do manual optimizations to your code, but there is no optimizer involved. Cheers, Kostas > On Feb 15, 2018, at 11:12 AM, Sahil Arora wrote: > > Hi Timo, > Thanks

Re: Optimizing multiple aggregate queries on a CEP using Flink

Hi Timo, Thanks a lot for the help. I will be looking forward to a reply from Kostas to be clearer on this. On Mon, 12 Feb 2018, 10:01 pm Timo Walther, wrote: > Hi Sahil, > > I'm not a CEP expert but I will loop in Kostas (in CC). In general, the > example that you

Re: Optimizing multiple aggregate queries on a CEP using Flink

Hi Sahil, I'm not a CEP expert but I will loop in Kostas (in CC). In general, the example that you described can be easily done with a ProcessFunction [1]. A process function not only allows to keep state (like a count) but also allows you to set timers flexibly for specific use cases such

Optimizing multiple aggregate queries on a CEP using Flink

Hi there, We have been working on a project with the title "Optimizing Multiple Aggregate Queries over a Complex Event Processing Engine". The aim is to optimize a group of queries. Take such as* "how many cars passed the post in the past 1 minute" *and* "how many cars passed the post in the past