summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/rpc_client/raw_client.cpp
diff options
context:
space:
mode:
authorachains <[email protected]>2025-11-10 16:32:52 +0300
committerachains <[email protected]>2025-11-10 17:26:03 +0300
commit28244e705d32f688896c3f2986d012d74fc1e487 (patch)
treec107ae43ed3c34840ba830965fb45e987f647fec /yt/cpp/mapreduce/rpc_client/raw_client.cpp
parent4a9fcc0815e9f0896644f22f0de847abffa8ebcc (diff)
YT-26425: Distributed API http proxy light requests
* Changelog entry Type: feature Component: cpp-sdk Support distributed API in C\+\+ SDK <Message for release notes> commit_hash:689a3c978864fa4623f3b38ce031faa96532b3fe
Diffstat (limited to 'yt/cpp/mapreduce/rpc_client/raw_client.cpp')
-rw-r--r--yt/cpp/mapreduce/rpc_client/raw_client.cpp65
1 files changed, 65 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/rpc_client/raw_client.cpp b/yt/cpp/mapreduce/rpc_client/raw_client.cpp
index dce55726cb6..64d51f87499 100644
--- a/yt/cpp/mapreduce/rpc_client/raw_client.cpp
+++ b/yt/cpp/mapreduce/rpc_client/raw_client.cpp
@@ -1426,6 +1426,71 @@ TCheckPermissionResponse ParseCheckPermissionResponse(const NApi::TCheckPermissi
return result;
}
+TDistributedWriteTableSessionWithCookies TRpcRawClient::StartDistributedWriteTableSession(
+ TMutationId& /*mutationId*/,
+ const TRichYPath& /*richPath*/,
+ i64 /*cookieCount*/,
+ const TStartDistributedWriteTableOptions& /*options*/)
+{
+ ythrow TApiUsageError() << "Not implemented";
+}
+
+void TRpcRawClient::PingDistributedWriteTableSession(
+ const TDistributedWriteTableSession& /*session*/,
+ const TPingDistributedWriteTableOptions& /*options*/)
+{
+ ythrow TApiUsageError() << "Not implemented";
+}
+
+void TRpcRawClient::FinishDistributedWriteTableSession(
+ TMutationId& /*mutationId*/,
+ const TDistributedWriteTableSession& /*session*/,
+ const TVector<TWriteTableFragmentResult>& /*results*/,
+ const TFinishDistributedWriteTableOptions& /*options*/)
+{
+ ythrow TApiUsageError() << "Not implemented";
+}
+
+std::unique_ptr<IOutputStreamWithResponse> TRpcRawClient::WriteTableFragment(
+ const TDistributedWriteTableCookie& /*cookie*/,
+ const TMaybe<TFormat>& /*format*/,
+ const TTableFragmentWriterOptions& /*options*/)
+{
+ ythrow TApiUsageError() << "Not implemented";
+}
+
+TDistributedWriteFileSessionWithCookies TRpcRawClient::StartDistributedWriteFileSession(
+ TMutationId& /*mutationId*/,
+ const TRichYPath& /*richPath*/,
+ i64 /*cookieCount*/,
+ const TStartDistributedWriteFileOptions& /*options*/)
+{
+ ythrow TApiUsageError() << "Not implemented";
+}
+
+void TRpcRawClient::PingDistributedWriteFileSession(
+ const TDistributedWriteFileSession& /*session*/,
+ const TPingDistributedWriteFileOptions& /*options*/)
+{
+ ythrow TApiUsageError() << "Not implemented";
+}
+
+void TRpcRawClient::FinishDistributedWriteFileSession(
+ TMutationId& /*mutationId*/,
+ const TDistributedWriteFileSession& /*session*/,
+ const TVector<TWriteFileFragmentResult>& /*results*/,
+ const TFinishDistributedWriteFileOptions& /*options*/)
+{
+ ythrow TApiUsageError() << "Not implemented";
+}
+
+std::unique_ptr<IOutputStreamWithResponse> TRpcRawClient::WriteFileFragment(
+ const TDistributedWriteFileCookie& /*cookie*/,
+ const TFileFragmentWriterOptions& /*options*/)
+{
+ ythrow TApiUsageError() << "Not implemented";
+}
+
TCheckPermissionResponse TRpcRawClient::CheckPermission(
const TString& user,
EPermission permission,