Hello all,

My question is basically whether it is possible to group events by a key
(these will belong to a specific transaction) and then calculate the
elapsed times between them based on a timestamp that is present in the
event.
So a transaction my have x events all timestamped and with the
transaction_id as key.
Is it possible to
1. group them by the key
2. order by the timestamp,
3. calculate the elapsed times between the steps/event
4. add that elapsed time to the step/event
5. output the modified events to the sink



Regards Hans

Reply via email to