Re: Java 8 lambdas for CEP patterns won't compile

2017-07-06 Thread David Koch
Thank you! Hoping to see Lambda support added back in soon as well. Regards, David On Mon, Jun 12, 2017 at 1:57 PM, Kostas Kloudas wrote: > Done. > > On Jun 12, 2017, at 12:24 PM, Ted Yu wrote: > > Can you add link to this thread in the JIRA

Re: Listening to timed-out patterns in Flink CEP

2017-06-11 Thread David Koch
Hello, It's been a while and I have never replied on the list. In fact, the fix committed by Till does work. Thanks! On Tue, Apr 25, 2017 at 9:37 AM, Moiz Jinia wrote: > Hey David, > Did that work for you? If yes could you share an example. I have a similar > use case -

Re: Listening to timed-out patterns in Flink CEP

2016-11-11 Thread David Koch
t; wrote: > >> Hi guys, >> >> I'll try to come up with an example illustrating the behaviour over the >> weekend. >> >> Cheers, >> Till >> >> On Fri, Oct 14, 2016 at 11:16 AM, David Koch <ogd...@googlemail.com> >> wrote: >>

Re: Listening to timed-out patterns in Flink CEP

2016-10-11 Thread David Koch
ain, how would the "not >>>>> match" be triggered if no event at all occurs? >>>>> >>>>> Good question. >>>>> >>>>> I'm not sure whether the following will work: >>>>> >>>>> This could be d

Re: Listening to timed-out patterns in Flink CEP

2016-10-11 Thread David Koch
at uses both of >>>> "notNext" (or "notFollowedBy") and "within" constructs. Something like >>>> this: >>>> >>>> Pattern<Event, ?> pattern = Pattern.begin("first") >>>> .notNext("second"

Re: Listening to timed-out patterns in Flink CEP

2016-10-09 Thread David Koch
he case of processing time, we could think about registering timeout > timers for processing time. However, I would highly recommend you to use > event time, because with processing time, Flink cannot guarantee meaningful > computations, because the events might arrive out of order. >