I am using flink CEP , and to match a event pattern in given time window we
use *.within(Time.days(1))*
Now in one of the case I need to wait for 1 working day instead of 1 day. Is
there any way to do that in Flink CEP?
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabb
Hi,
I'm afraid, Flink CEP does not distinguish work days from non-work days.
Of course, you could implement the logic in a DataStream program (probably
using ProcessFunction).
Best, Fabian
2018-03-20 15:44 GMT+01:00 shishal :
> I am using flink CEP , and to match a event pattern in given time w
Thanks Fabian,
So by non working day, I mean, I have a list of non working day in a year,
which I can use to compare.
I am very new to Flink and Flick CEP. Initially I thought there is a way to
have within(time) value expression dynamically. So now I guess that's not
possible.
If I understand c
Hi,
I don't think the CEP library is that flexible, but I loop in Kostas (CC)
who knows more about it.
I'm not exactly sure what you mean by "manipulate" event-time, but I don't
think that's necessary.
You can implement rules also with state and timers in the ProcessFunction.
The function ingests