Я работаю с потоком Kinesis, который хранит в моем хранилище данных все события платформы.
Итак, у меня есть таблица, которая содержит рабочие сеансы сотрудника и содержит статус работысеанс, время обновления, ревизия записи и т. д. и т. д .:
Моя таблица выглядит примерно так:
+-------------------+-----------+-----------------------+-------+
| w.work_session_id | s.name | w.updated_at | w.rev |
+-------------------+-----------+-----------------------+-------+
| 1 |available | 2019-02-20 20:00:01 | 1 |
+-------------------+-----------+-----------------------+-------+
| 1 |available | 2019-02-20 20:00:02 | 2 |
+-------------------+-----------+-----------------------+-------+
| 1 |break | 2019-02-20 20:00:04 | 5 |
+-------------------+-----------+-----------------------+-------+
| 1 |available | 2019-02-20 20:00:10 | 9 |
+-------------------+-----------+-----------------------+-------+
| 2 |available | 2019-02-20 20:19:50 | 1 |
+-------------------+-----------+-----------------------+-------+
| 3 |dashboard | 2019-02-20 20:20:20 | 1 |
+-------------------+-----------+-----------------------+-------+
| 1 |available | 2019-02-20 20:21:00 | 15 |
+-------------------+-----------+-----------------------+-------+
И главная проблема в том, что я не могу сохранить в другой таблицесколько раз был сотрудник в каждом статусе и сколько времени.Я пробовал с оконной функцией, но никогда не использовал их раньше, и я немного растерялся по этому поводу.Любая помощь будет оценена.Спасибо.