В v1 ETL перезагружал слои целиком (full refresh) на каждый модельный день.
Для v2 смысл задачи сохраняется, но форма другая: спека предписывает конвейер
без TRUNCATE — поток append-only в ReplacingMergeTree и переобработку по
дневным партициям, поздние заказы поглощает только ODS (раздел 6).
Инкрементальность в спеку не входит намеренно (раздел 10: «Инкрементальный
ETL — свой issue»).
Что решить
нужна ли инкрементальность поверх переобработки дневных партиций и где
именно она даёт учебную ценность
где хранится точка отсчёта загрузки по каждой таблице и какой запас
берётся на опоздавшие данные
поведение при падении прогона и повторном запуске (идемпотентность)
Тело исходного issue не сохранилось: он был закрыт как wontfix ещё до
переезда трекера с GitHub, и при переносе в Gitea перенесли только название.
Постановка выше восстановлена по названию, плану v1 и разделам 6 и 10 спеки v2.
Переехало из репозитория-предшественника:
https://git.dementev.space/ddmitry/clickstream-ch-kafka-superset-demo/issues/8
## Что за долг
В v1 ETL перезагружал слои целиком (full refresh) на каждый модельный день.
Для v2 смысл задачи сохраняется, но форма другая: спека предписывает конвейер
без TRUNCATE — поток append-only в ReplacingMergeTree и переобработку по
дневным партициям, поздние заказы поглощает только ODS (раздел 6).
Инкрементальность в спеку не входит намеренно (раздел 10: «Инкрементальный
ETL — свой issue»).
## Что решить
- [ ] нужна ли инкрементальность поверх переобработки дневных партиций и где
именно она даёт учебную ценность
- [ ] где хранится точка отсчёта загрузки по каждой таблице и какой запас
берётся на опоздавшие данные
- [ ] поведение при падении прогона и повторном запуске (идемпотентность)
## Опорный материал
Утверждённый, но не реализованный план из v1:
https://git.dementev.space/ddmitry/clickstream-ch-kafka-superset-demo/src/branch/main/plans/incremental-etl-v2.md
## Оговорка о переносе
Тело исходного issue не сохранилось: он был закрыт как `wontfix` ещё до
переезда трекера с GitHub, и при переносе в Gitea перенесли только название.
Постановка выше восстановлена по названию, плану v1 и разделам 6 и 10 спеки v2.
Тикет — техдолг, переехавший с предыдущего стенда, а не долг этого. Здесь выбор уже сделан и записан: конвейер живёт на пересборке по дневным партициям, объём выводится из world_position и состояния слоёв (#135, etl.md), параметров у запуска нет. Приёмка этапа 4 (#6) подтвердила, что повторный прогон не меняет делового содержимого витрин. Инкрементальность на стенде не окупается: её цена — сложность, которую менти пришлось бы расшифровывать по дороге к уроку.
Тема при этом не выброшена: учебная ценность инкрементального пересчёта живёт в идее лабы #149 — менти строит инкрементальный daily_traffic сам, против готового оракула сверки.
Закрыт как wontfix — решением, не работой.
Тикет — техдолг, переехавший с предыдущего стенда, а не долг этого. Здесь выбор уже сделан и записан: конвейер живёт на пересборке по дневным партициям, объём выводится из world_position и состояния слоёв (#135, etl.md), параметров у запуска нет. Приёмка этапа 4 (#6) подтвердила, что повторный прогон не меняет делового содержимого витрин. Инкрементальность на стенде не окупается: её цена — сложность, которую менти пришлось бы расшифровывать по дороге к уроку.
Тема при этом не выброшена: учебная ценность инкрементального пересчёта живёт в идее лабы #149 — менти строит инкрементальный daily_traffic сам, против готового оракула сверки.
Blocking a user prevents them from interacting with repositories, such as opening or commenting on pull requests or issues. Learn more about blocking a user.
Переехало из репозитория-предшественника:
ddmitry/clickstream-ch-kafka-superset-demo#8
Что за долг
В v1 ETL перезагружал слои целиком (full refresh) на каждый модельный день.
Для v2 смысл задачи сохраняется, но форма другая: спека предписывает конвейер
без TRUNCATE — поток append-only в ReplacingMergeTree и переобработку по
дневным партициям, поздние заказы поглощает только ODS (раздел 6).
Инкрементальность в спеку не входит намеренно (раздел 10: «Инкрементальный
ETL — свой issue»).
Что решить
именно она даёт учебную ценность
берётся на опоздавшие данные
Опорный материал
Утверждённый, но не реализованный план из v1:
https://git.dementev.space/ddmitry/clickstream-ch-kafka-superset-demo/src/branch/main/plans/incremental-etl-v2.md
Оговорка о переносе
Тело исходного issue не сохранилось: он был закрыт как
wontfixещё допереезда трекера с GitHub, и при переносе в Gitea перенесли только название.
Постановка выше восстановлена по названию, плану v1 и разделам 6 и 10 спеки v2.
Закрыт как wontfix — решением, не работой.
Тикет — техдолг, переехавший с предыдущего стенда, а не долг этого. Здесь выбор уже сделан и записан: конвейер живёт на пересборке по дневным партициям, объём выводится из world_position и состояния слоёв (#135, etl.md), параметров у запуска нет. Приёмка этапа 4 (#6) подтвердила, что повторный прогон не меняет делового содержимого витрин. Инкрементальность на стенде не окупается: её цена — сложность, которую менти пришлось бы расшифровывать по дороге к уроку.
Тема при этом не выброшена: учебная ценность инкрементального пересчёта живёт в идее лабы #149 — менти строит инкрементальный daily_traffic сам, против готового оракула сверки.