I have stream of data like
Eventname, Event id, Start_time ( Time Stamp)
..
here I want to apply window transformation on last field Start_time
which is of time stamp, my requirement is like I want to take data for last 30 minuts.
so what I see in flink window is something this .timeWindow(Time.minutes(30))
so I guess it take events of last 30 minutes but not respect to start_time
I want to take data where start_time is withing last 30 minuts, then how I write that transormation? do I need to use filter
using that column ?
I am new to flink.
Thanks