Hi, surely really new-bye question but Flink sounds like to be the best choice. I have a log continuously added to a database table where a machine status is stored with a timestamp (the status is 0, 1, 2).
What I need is to process this status and produce another stream where a sequence of status X is aggregated producing a new record with the first status X timestamp found in the input stream and the time delta until a new status different from X is seen. A datastream to connect to a table is available? I've tried to find something in the documentation, but not sure if I searched in the right place. I Flick an optimal option for that rather simple processing? Thank you, Stefano.
