diff options
| author | hiddenpath <[email protected]> | 2024-12-13 15:22:36 +0300 |
|---|---|---|
| committer | hiddenpath <[email protected]> | 2024-12-13 17:04:18 +0300 |
| commit | 09c88b035d29fac5fd49de2fbc3c71e2d2a80754 (patch) | |
| tree | a84b5b2de4dcdf85c3b22b9cac7e984aebb8b68d /yt/cpp/mapreduce/client/client_writer.cpp | |
| parent | 615edba542d9394b0eae47ef957ec2257549cfdd (diff) | |
yt/cpp/mapreduce: move Get, TryGet, Exists, MultisetAttributes to THttpRawClient
commit_hash:bd2228f98fa92de408ca850f9bc1608fdf99e7f5
Diffstat (limited to 'yt/cpp/mapreduce/client/client_writer.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/client/client_writer.cpp | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/yt/cpp/mapreduce/client/client_writer.cpp b/yt/cpp/mapreduce/client/client_writer.cpp index ee14ee0eb2c..84e0802ee23 100644 --- a/yt/cpp/mapreduce/client/client_writer.cpp +++ b/yt/cpp/mapreduce/client/client_writer.cpp @@ -1,19 +1,23 @@ #include "client_writer.h" #include "retryful_writer.h" -#include "retryless_writer.h" #include "retryful_writer_v2.h" +#include "retryless_writer.h" -#include <yt/cpp/mapreduce/interface/io.h> #include <yt/cpp/mapreduce/common/fwd.h> #include <yt/cpp/mapreduce/common/helpers.h> +#include <yt/cpp/mapreduce/interface/io.h> + +#include <yt/cpp/mapreduce/raw_client/raw_client.h> + namespace NYT { //////////////////////////////////////////////////////////////////////////////// TClientWriter::TClientWriter( const TRichYPath& path, + const IRawClientPtr& rawClient, IClientRetryPolicyPtr clientRetryPolicy, ITransactionPingerPtr transactionPinger, const TClientContext& context, @@ -38,6 +42,7 @@ TClientWriter::TClientWriter( auto serializedWriterOptions = FormIORequestParameters(options); RawWriter_ = MakeIntrusive<NPrivate::TRetryfulWriterV2>( + rawClient, std::move(clientRetryPolicy), std::move(transactionPinger), context, @@ -50,6 +55,7 @@ TClientWriter::TClientWriter( options.CreateTransaction_); } else { RawWriter_.Reset(new TRetryfulWriter( + rawClient, std::move(clientRetryPolicy), std::move(transactionPinger), context, |
