diff options
author | whatsername <whatsername@yandex-team.com> | 2023-11-20 23:08:43 +0300 |
---|---|---|
committer | whatsername <whatsername@yandex-team.com> | 2023-11-21 00:38:32 +0300 |
commit | a4dca696db802127945391cef62a30b91201a2af (patch) | |
tree | 5ead7c505137f7351f0cf6d1d58812cf134a65b2 /yt/cpp/mapreduce/io/job_writer.h | |
parent | a3fd9aa6b812dc5e1eb456b2cfc101417ade4040 (diff) | |
download | ydb-a4dca696db802127945391cef62a30b91201a2af.tar.gz |
Fix ussues for SingleTableJobWriter
Diffstat (limited to 'yt/cpp/mapreduce/io/job_writer.h')
-rw-r--r-- | yt/cpp/mapreduce/io/job_writer.h | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/yt/cpp/mapreduce/io/job_writer.h b/yt/cpp/mapreduce/io/job_writer.h index fb962d9449..9c298ae5fe 100644 --- a/yt/cpp/mapreduce/io/job_writer.h +++ b/yt/cpp/mapreduce/io/job_writer.h @@ -15,16 +15,17 @@ namespace NDetail { //////////////////////////////////////////////////////////////////////////////// -class TJobWriterStream { +class TJobWriterStream +{ public: explicit TJobWriterStream(int fd); explicit TJobWriterStream(const TFile& file); - ~TJobWriterStream(); + ~TJobWriterStream() = default; public: static constexpr size_t BufferSize = 1 << 20; - TFile FdFile; - TUnbufferedFileOutput FdOutput; + TFile FDFile; + TUnbufferedFileOutput FDOutput; TBufferedOutput BufferedOutput; }; @@ -47,7 +48,7 @@ public: void OnRowFinished(size_t tableIndex) override; private: - TVector<THolder<NDetail::TJobWriterStream>> Streams_; + TVector<std::unique_ptr<NDetail::TJobWriterStream>> Streams_; }; //////////////////////////////////////////////////////////////////////////////// @@ -65,7 +66,7 @@ public: private: const size_t TableIndex_; - THolder<NDetail::TJobWriterStream> Stream_; + std::unique_ptr<NDetail::TJobWriterStream> Stream_; }; //////////////////////////////////////////////////////////////////////////////// |