Flink CEP window for 1 working day

[shishal]

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.nabble.com/

[Fabian Hueske-2]

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 <[hidden email]>:

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.nabble.com/

[shishal]

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 correctly, the other way around is to somehow manipulated
stream (probably using ProcessFunction), and may be manipulate event time.

Can you please help me with more pointer to how to go ahead with this.
Please note that I am using event time processing.

Your help is much appreciated.
Thanks



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Fabian Hueske-2]

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 events and evaluates the rules.

To account for out of order data, you can process when a timer fires which happens when the watermark advanced to that point in time.

Best, Fabian

2018-03-20 16:11 GMT+01:00 shishal <[hidden email]>:

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 correctly, the other way around is to somehow manipulated
stream (probably using ProcessFunction), and may be manipulate event time.

Can you please help me with more pointer to how to go ahead with this.
Please note that I am using event time processing.

Your help is much appreciated.
Thanks

--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/