summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/client/client.cpp
diff options
context:
space:
mode:
authorhiddenpath <[email protected]>2025-02-18 20:34:08 +0300
committerhiddenpath <[email protected]>2025-02-18 21:38:01 +0300
commitf29f61716d400e5eeb90d62ae9fc5ec0b7d3a39f (patch)
tree13b56a5db70e3c3773dabe0cc79279f614660e0c /yt/cpp/mapreduce/client/client.cpp
parent7fed694a0b014cec505a8117fc4be52cbf9792aa (diff)
YT-23616: Temprorary fallback to http implementation for some methods
This commit should be reverted when these methods will have corresponding RPC implementations. ``` void TRpcRawClient::DeleteRows( const TYPath& /*path*/, const TNode::TListType& /*keys*/, const TDeleteRowsOptions& /*options*/) { YT_UNIMPLEMENTED(); } ``` commit_hash:a7957f365cc49dce53d44d702288a41cb2ec45b9
Diffstat (limited to 'yt/cpp/mapreduce/client/client.cpp')
-rw-r--r--yt/cpp/mapreduce/client/client.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/yt/cpp/mapreduce/client/client.cpp b/yt/cpp/mapreduce/client/client.cpp
index 48e66435ab4..004bfaf2d86 100644
--- a/yt/cpp/mapreduce/client/client.cpp
+++ b/yt/cpp/mapreduce/client/client.cpp
@@ -1178,7 +1178,7 @@ void TClient::InsertRows(
RequestWithRetry<void>(
ClientRetryPolicy_->CreatePolicyForGenericRequest(),
[this, &path, &rows, &options] (TMutationId /*mutationId*/) {
- RawClient_->InsertRows(path, rows, options);
+ NRawClient::InsertRows(Context_, path, rows, options);
});
}
@@ -1191,7 +1191,7 @@ void TClient::DeleteRows(
RequestWithRetry<void>(
ClientRetryPolicy_->CreatePolicyForGenericRequest(),
[this, &path, &keys, &options] (TMutationId /*mutationId*/) {
- RawClient_->DeleteRows(path, keys, options);
+ NRawClient::DeleteRows(Context_, path, keys, options);
});
}
@@ -1218,7 +1218,7 @@ TNode::TListType TClient::LookupRows(
return RequestWithRetry<TNode::TListType>(
ClientRetryPolicy_->CreatePolicyForGenericRequest(),
[this, &path, &keys, &options] (TMutationId /*mutationId*/) {
- return RawClient_->LookupRows(path, keys, options);
+ return NRawClient::LookupRows(Context_, path, keys, options);
});
}