aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/io/job_writer.h
diff options
context:
space:
mode:
authorwhatsername <whatsername@yandex-team.com>2023-11-20 23:08:43 +0300
committerwhatsername <whatsername@yandex-team.com>2023-11-21 00:38:32 +0300
commita4dca696db802127945391cef62a30b91201a2af (patch)
tree5ead7c505137f7351f0cf6d1d58812cf134a65b2 /yt/cpp/mapreduce/io/job_writer.h
parenta3fd9aa6b812dc5e1eb456b2cfc101417ade4040 (diff)
downloadydb-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.h13
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_;
};
////////////////////////////////////////////////////////////////////////////////