diff options
| author | achains <[email protected]> | 2025-12-12 11:12:23 +0300 |
|---|---|---|
| committer | achains <[email protected]> | 2025-12-12 11:27:31 +0300 |
| commit | 3bd4aa5fcb0f9a73ef9fcc548c26a0aa81011981 (patch) | |
| tree | 59278b0d6fe997b5caa3ad0e2a83b9b99cd70714 /yt/cpp/mapreduce/rpc_client/rpc_parameters_serialization.cpp | |
| parent | 485533da7c2417a6cc55d65af62740ff85a109a5 (diff) | |
YT-26906: start session from tx
* Changelog entry
Type: feature
Component: cpp-sdk
Start distributed session methods (file/table) now support attaching to transaction.
commit_hash:0a40dfd6d556f9890fa5abccf29c0baf33df4e7d
Diffstat (limited to 'yt/cpp/mapreduce/rpc_client/rpc_parameters_serialization.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/rpc_client/rpc_parameters_serialization.cpp | 4 |
1 files changed, 4 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 d713b882b9f..265ce8a66ba 100644 --- a/yt/cpp/mapreduce/rpc_client/rpc_parameters_serialization.cpp +++ b/yt/cpp/mapreduce/rpc_client/rpc_parameters_serialization.cpp @@ -1181,10 +1181,12 @@ NApi::TPartitionTablesOptions SerializeOptionsForGetTablePartitions( NApi::TDistributedWriteSessionStartOptions SerializeOptionsForStartDistributedTableSession( TMutationId& /*mutationId*/, + const TTransactionId& transactionId, i64 cookieCount, const TStartDistributedWriteTableOptions& options) { NApi::TDistributedWriteSessionStartOptions result; + SetTransactionId(&result, transactionId); result.CookieCount = cookieCount; // TODO(achains): Uncomment when TMutatingOptions are supported in native client distributed API. @@ -1210,10 +1212,12 @@ NApi::TDistributedWriteSessionFinishOptions SerializeOptionsForFinishDistributed NApi::TDistributedWriteFileSessionStartOptions SerializeOptionsForStartDistributedFileSession( TMutationId& /*mutationId*/, + const TTransactionId& transactionId, i64 cookieCount, const TStartDistributedWriteFileOptions& options) { NApi::TDistributedWriteFileSessionStartOptions result; + SetTransactionId(&result, transactionId); result.CookieCount = cookieCount; // TODO(achains): Uncomment when TMutatingOptions are supported in native client distributed API. |