Как проектировать идемпотентную загрузку партиции?

Пишите в staging → атомарная замена partition / MERGE по ключу периода; либо DELETE WHERE dt={{ds}} + INSERT. Rerun того же ds даёт тот же снимок.

Разбор

• Избегайте APPEND без дедупа.
• Фиксируйте schema и late data стратегию.
• Вакуум/компакция в озере — отдельный процесс.
• Тест: clear task дважды и сравните checksum.

Итог

Идемпотентная загрузка = overwrite/merge периода, проверяемый повторным clear.