summaryrefslogtreecommitdiffstats
path: root/contrib/python/ipython/py3/IPython/extensions
diff options
context:
space:
mode:
authoralkaline <[email protected]>2026-05-30 13:18:28 +0300
committeralkaline <[email protected]>2026-05-30 13:39:17 +0300
commit230f2a6d4705cfec902a5393a7e8df346f15bd00 (patch)
tree55a1ca441658c99ee2360d15a5531ed64c8c2dac /contrib/python/ipython/py3/IPython/extensions
parente34f7711232faaab901bace6eeebd2088a893112 (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