YT-26425: RPC support distributed API

* Changelog entry
  Type: feature
  Component: cpp-sdk

Support Distributed write API methods for RPC proxies in C\+\+ client.
commit_hash:1b1247f95c77a2de02d16f56dcc3291e772be2f2

1 files changed, 58 insertions, 0 deletions

diff --git a/yt/cpp/mapreduce/rpc_client/rpc_parameters_serialization.cpp b/yt/cpp/mapreduce/rpc_client/rpc_parameters_serialization.cpp
index d8f36e16b6c..f5b0f2460a7 100644
--- a/yt/cpp/mapreduce/rpc_client/rpc_parameters_serialization.cpp
+++ b/yt/cpp/mapreduce/rpc_client/rpc_parameters_serialization.cpp
@@ -1179,6 +1179,64 @@ NApi::TPartitionTablesOptions SerializeOptionsForGetTablePartitions(
     return result;
 }
 
+NApi::TDistributedWriteSessionStartOptions SerializeOptionsForStartDistributedTableSession(
+    TMutationId& /*mutationId*/,
+    i64 cookieCount,
+    const TStartDistributedWriteTableOptions& options)
+{
+    NApi::TDistributedWriteSessionStartOptions result;
+
+    result.CookieCount = cookieCount;
+    // TODO(achains): Uncomment when TMutatingOptions are supported in native client distributed API.
+    // SetMutationId(&result, mutationId);
+
+    if (options.Timeout_) {
+        result.Timeout = *options.Timeout_;
+    }
+
+    return result;
+}
+
+NApi::TDistributedWriteSessionFinishOptions SerializeOptionsForFinishDistributedTableSession(
+    TMutationId& /*mutationId*/,
+    const TFinishDistributedWriteTableOptions& /*options*/)
+{
+    NApi::TDistributedWriteSessionFinishOptions result;
+
+    // TODO(achains): Uncomment when TMutatingOptions are supported in native client distributed API.
+    // SetMutationId(&result, mutationId);
+    return result;
+}
+
+NApi::TDistributedWriteFileSessionStartOptions SerializeOptionsForStartDistributedFileSession(
+    TMutationId& /*mutationId*/,
+    i64 cookieCount,
+    const TStartDistributedWriteFileOptions& options)
+{
+    NApi::TDistributedWriteFileSessionStartOptions result;
+
+    result.CookieCount = cookieCount;
+    // TODO(achains): Uncomment when TMutatingOptions are supported in native client distributed API.
+    // SetMutationId(&result, mutationId);
+
+    if (options.Timeout_) {
+        result.Timeout = *options.Timeout_;
+    }
+
+    return result;
+}
+
+NApi::TDistributedWriteFileSessionFinishOptions SerializeOptionsForFinishDistributedFileSession(
+    TMutationId& /*mutationId*/,
+    const TFinishDistributedWriteFileOptions& /*options*/)
+{
+    NApi::TDistributedWriteFileSessionFinishOptions result;
+
+    // TODO(achains): Uncomment when TMutatingOptions are supported in native client distributed API.
+    // SetMutationId(&result, mutationId);
+    return result;
+}
+
 ////////////////////////////////////////////////////////////////////////////////
 
 } // namespace NYT::NDetail