diff options
| author | alkaline <[email protected]> | 2026-05-30 13:18:28 +0300 |
|---|---|---|
| committer | alkaline <[email protected]> | 2026-05-30 13:39:17 +0300 |
| commit | 230f2a6d4705cfec902a5393a7e8df346f15bd00 (patch) | |
| tree | 55a1ca441658c99ee2360d15a5531ed64c8c2dac /contrib/python/ipython/py3/IPython/extensions | |
| parent | e34f7711232faaab901bace6eeebd2088a893112 (diff) | |
add LockType option to TInsertRowsOptions in yt/cpp/mapreduce
YT-драйвер уже принимает параметр lock_type для insert_rows
(<https://nda.ya.ru/t/y1DKR88L7dogTW>),
но C\+\+ mapreduce-клиент не пробрасывает его дальше, поэтому вызывающий
код всегда использует ELockType::Exclusive.
В груте есть задача инициализации табличных (внешних) счётчиков:
тасклет считает map-reduce-ом дельты по всем владельцам и батчами пишет
их в общую динтаблицу (<https://nda.ya.ru/t/4G2o2Jdo7dogTX> и аналоги), куда рантайм
одновременно дописывает инкременты на каждое событие в источнике.
Колонка `value` в такой таблице — aggregate-sum;
рантайм через NApi пишет в неё с lock_type=shared_write, чтобы параллельные
записи не конфликтовали. Тасклет инциализации счетчика же ходит через mapreduce-клиент и в нем тоже хочется уметь брать shared_write lock.
(<https://nda.ya.ru/t/WrJ9_kf77dogTb>).
commit_hash:7cbcd19f8d0532d6cf0e7f48abe197bb7fda99d3
Diffstat (limited to 'contrib/python/ipython/py3/IPython/extensions')
0 files changed, 0 insertions, 0 deletions
