Hi Martin, you need to implement you own policy. However, this should be be complicated. Have a look at "TimeTriggerPolicy". You just need to provide a "Timestamp" implementation that extracts you ts-attribute from the tuples.
-Matthias On 08/28/2015 03:58 PM, Martin Neumann wrote: > Hej, > > I have a stream of timestamped events I want to process in Flink streaming. > Di I have to write my own policies to do so, or can define time based > windows to use the timestamps instead of the system time? > > cheers Martin
signature.asc
Description: OpenPGP digital signature
