New to flink and looking for some guidance on aggregating stream data preferably using SQL over a 60 day window - 1. Input - a stream of events where each event has

user_id, price, event_timestamp

2. Output - every 1 minute aggregate

min(price) and max(price)

by

user_id

for the past 60 days Was hoping to use sliding/hop windows of size 60 that slide every 1 min but seems like the first aggregation won't be available until first 60 days are completed. Is OVER the only windowing option for this case or am I missing something about sliding windows?