Подскажите, как лучше всего задизайнить инкрементальный ETL, который агрегирует ивенты в сессии и считает для каждой сессии определённые метрики. Вопрос в сессиях, которые могли начаться раньше инкремента - как правильно пересчитать для них метрики? Понятно, что мы можем сделать coalesce инкремента с предыдущим состоянием. Но если к примеру у нас одна из метрик это сумма ивентов, то как избежать многоразового суммирования, если потребуется несколько раз бэкфиллить таблицу?