Hi:

I am trying to filter out records which are lagging behind (based on event time) by a certain amount of time.  

Is the watermark api applicable to this scenario (ie, filtering lagging records) or it is only applicable with aggregation ?  I could not get a clear understanding from the documentation which only refers to it's usage with aggregation.

Thanks

Mans