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 <shisha...@gmail.com>: > 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/ >
