summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/client/client_writer.cpp
diff options
context:
space:
mode:
authorhiddenpath <[email protected]>2024-12-13 15:22:36 +0300
committerhiddenpath <[email protected]>2024-12-13 17:04:18 +0300
commit09c88b035d29fac5fd49de2fbc3c71e2d2a80754 (patch)
treea84b5b2de4dcdf85c3b22b9cac7e984aebb8b68d /yt/cpp/mapreduce/client/client_writer.cpp
parent615edba542d9394b0eae47ef957ec2257549cfdd (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.cpp10
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,