diff options
| author | achains <[email protected]> | 2025-11-10 16:32:52 +0300 |
|---|---|---|
| committer | achains <[email protected]> | 2025-11-10 17:26:03 +0300 |
| commit | 28244e705d32f688896c3f2986d012d74fc1e487 (patch) | |
| tree | c107ae43ed3c34840ba830965fb45e987f647fec /yt/cpp/mapreduce/rpc_client/raw_client.cpp | |
| parent | 4a9fcc0815e9f0896644f22f0de847abffa8ebcc (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.cpp | 65 |
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, |
