Как синхронизировать воспроизведение медиа по ненадежной сети?

Вы хотите использовать lag() для этого, но вы должны быть осторожны с фильтрацией даты. Итак, я думаю, вы хотите:

SELECT prev_membership_type, membership_type,
       COUNT(*) as num_changes,
       COUNT(DISTINCT member) as num_members
FROM (SELECT mddc.*,
             LAG(mddc.membership_type) OVER (PARTITION BY mddc.customer_id ORDER BY mddc.date) as prev_membership_type
      FROM member_detail_daily_changes_new mddc
     ) mddc
WHERE prev_membership_type <> membership_type AND
      date >= '2018-01-01' AND
      date < '2019-01-01'
GROUP BY membership_type, prev_membership_type;

Примечания:

• Фильтрация по date должна произойти после вычисления lag().
• При этом учитывается, что члены могут иметь определенный тип в 2017 году, а затем перейти на новый тип в 2018.
• Фильтрация даты совместима с индексами.
• Рассчитаны два значения. Одним из них является общее количество изменений. Другой подсчитывает каждого члена только один раз для каждого типа изменений.