diff options
| author | arkady-e1ppa <arkady-e1ppa@yandex-team.com> | 2024-04-25 12:10:07 +0300 |
|---|---|---|
| committer | arkady-e1ppa <arkady-e1ppa@yandex-team.com> | 2024-04-25 12:24:28 +0300 |
| commit | 0d4d48be8da7262d2ce16251e75cac692db6fa10 (patch) | |
| tree | 6404e9e05b305919b844acbcedf2eebac3ff3b1b /library/cpp | |
| parent | bae4fe8e1e7bd4c033bb805afb1af43277b785ef (diff) | |
| download | ydb-0d4d48be8da7262d2ce16251e75cac692db6fa10.tar.gz | |
YT-20013: Introduce use_delivery_fenced_pipe_writer to improve granularity of job interrupt
yt/core: Added DeliveryFencedWriteOperation and corresponding Writer which complete their action only when written data has been read from the pipe (read operation itself may fail, but we only care about pipe emptiness)
yt/server: Added UseDeliveryFencedPipeWriter option which forces jobs to use such writer. This makes it so that at any given moment pipe can contain only up to buffer_row_count rows of data and the next batch will be started only after the previous one is consumed. This would allow for a more precise interruptions
8a1ffb00b64ee0caa8b7926b76ba20120b9abedd
Diffstat (limited to 'library/cpp')
0 files changed, 0 insertions, 0 deletions