hi all! I'm just starting my way with flink and I have a design question.
I'm trying to aggregate incoming events (source: kafka topic) on a 10min tumbling window in order to calculate the incoming events rate (total per minute). I would like to take this window and perform an additional window (60 min) in order to calculate percentiles, std deviation and some other statistics on that time window. finally I would like to trigger some business logic in case the calculation hits a certain threshold. my main challenge is - how to chain the two windows together. any help is appreciated (please send scala example code - I'm not using java :) for this project)
