FFORGE//RS
← Маршрут

distributed systems / УРОВЕНЬ 4

Миллион одно-row inserts

ОЦЕНКА50 МИН
01

ТЕОРИЯ / ВОСПРОИЗВЕДЕНИЕ

Что нужно восстановить

  • Batch по rows/bytes, сортировать по locality и deduplicate highest version

Batch ограничивает part pressure

One-row inserts создают small parts и merge/metadata overhead. Bounded batch амортизирует cost, но лимиты обязаны ограничивать latency и memory; replay identity сохраняет highest version перед sorting.

КОНТРОЛЬНАЯ ТОЧКА

Почему тысячи one-row inserts хуже bounded batches для MergeTree?

ISOLATED RUST 1.96
src/lib.rsРЕДАКТИРОВАНИЕ

02 / РЕАЛИЗАЦИЯ

Реализуйте контракт

Подготовьте batches: deduplicate `(tenant_id,event_id)` по highest version; sort tenant/timestamp/event; split max_rows/max_bytes; zero limits и row, не помещающаяся одна, rejected.

Инициализация редактора…
ОБЛАЧНЫЙ SANDBOXсеть выключена · 256 МБ · 12 с
1 / 64 KB
ВЫВОД
Runner ждёт отправки кода.