diff options
| author | nadya73 <nadya73@yandex-team.com> | 2023-09-14 21:38:24 +0300 |
|---|---|---|
| committer | nadya73 <nadya73@yandex-team.com> | 2023-09-14 21:58:35 +0300 |
| commit | 66ab4dcacadc42a49d252c99d3f7666f13a5abe1 (patch) | |
| tree | 94f38106381f9b5d36da767491c344972a28c547 /yt/cpp/mapreduce/io/yamr_table_writer.cpp | |
| parent | 59dbf512fa4bb44d4873c2dd926eb95a57895472 (diff) | |
| download | ydb-66ab4dcacadc42a49d252c99d3f7666f13a5abe1.tar.gz | |
[yt/cpp/mapreduce] YT-19268: Lock memory for parallel writer
Diffstat (limited to 'yt/cpp/mapreduce/io/yamr_table_writer.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/io/yamr_table_writer.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/io/yamr_table_writer.cpp b/yt/cpp/mapreduce/io/yamr_table_writer.cpp index cce7ceb0f0..fe31eb5543 100644 --- a/yt/cpp/mapreduce/io/yamr_table_writer.cpp +++ b/yt/cpp/mapreduce/io/yamr_table_writer.cpp @@ -13,6 +13,11 @@ TYaMRTableWriter::TYaMRTableWriter(THolder<IProxyOutput> output) TYaMRTableWriter::~TYaMRTableWriter() { } +size_t TYaMRTableWriter::GetBufferMemoryUsage() const +{ + return Output_->GetBufferMemoryUsage(); +} + size_t TYaMRTableWriter::GetTableCount() const { return Output_->GetStreamCount(); |