Hi,
in flink sql, can i acheive a usecase where i need to start a window on a specific condition, independently without affecting rest of the events
for e.g. if i have 10 events 5 of them have x = 1, y = 1 and other 5 have x = 2, y = 1 now i need to start a window as soon as the 1st x = 1 event comes and aggregate all the events for x = 1 for a given time lets say 1 min. other events with x = 2 should not be aggregated so at the end i should have 6 events (5 events with x = 2 and one aggregated event with x = 1)
i have implemented the above usecase with datastream using processFunctions onTimer method, i need help with SQL