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 ?
>
> Cheers
>
> On Mon, Jun 12, 2017 at 3:15 AM, K
Hello,
I cannot get patterns expressed as lambdas like:
Pattern pattern1 = Pattern. begin("start")
.where(evt -> evt.key.length() > 0)
.next("last").where(evt -> evt.key.length() >
0).within(Time.seconds(5));
to compile with Flink 1.3.0. My IDE doesn't handle it and building on
command l
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 - need to get notified of
t;>
>> 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
>> wrote:
>>
>>> Hello,
>>>
>>> Thanks for th
}
> lastEmittedWM = waterMarkTmst
>
> System.out.println(String.format("Watermark at %s", new
> Date(waterMarkTmst)));
> return new Watermark(waterMarkTmst);//Until an event is
> seem WM==0 starts advancing by 1000ms until an
gt;>>
>>>>> Good question.
>>>>>
>>>>> I'm not sure whether the following will work:
>>>>>
>>>>> This could be done by creating a CEP matching pattern that uses both
>>>>> of "notNext" (or "notFollowedB
t;> Good question.
>>>>
>>>> I'm not sure whether the following will work:
>>>>
>>>> This could be done by creating a CEP matching pattern that uses both of
>>>> "notNext" (or "notFollowedBy") and "within"
ng 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.
>
> Cheers,
> Till
>
> On Thu, Oct 6, 2016 at 3:08 PM, David Koch wrote:
>
>
Hello,
With Flink CEP, is there a way to actively listen to pattern matches that
time out? I am under the impression that this is not possible.
In my case I partition a stream containing user web navigation by "userId"
to look for sequences of Event A, followed by B within 4 seconds for each
user
Hello,
Is FlinkCEP applicable to large key spaces with potentially long timeouts
between events that define a pattern? Ideally, without ridiculous hardware.
More concretely, we segment users (one key per user) based on sequences of
events for that user.
A segment "Abandoned Cart" may be defined
10 matches
Mail list logo
