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/interface | |
| 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/interface')
| -rw-r--r-- | yt/cpp/mapreduce/interface/client.h | 34 | ||||
| -rw-r--r-- | yt/cpp/mapreduce/interface/raw_client.h | 2 |
2 files changed, 20 insertions, 16 deletions
diff --git a/yt/cpp/mapreduce/interface/client.h b/yt/cpp/mapreduce/interface/client.h index e5032e10970..27c248afc1e 100644 --- a/yt/cpp/mapreduce/interface/client.h +++ b/yt/cpp/mapreduce/interface/client.h @@ -150,6 +150,24 @@ public: const TStartTransactionOptions& options = TStartTransactionOptions()) = 0; /// + /// @brief Initialize distributed file session and request cookies for participants. + /// + /// @see [YT doc](https://ytsaurus.tech/docs/en/api/commands#start_distributed_write_file_session) + virtual TDistributedWriteFileSessionWithCookies StartDistributedWriteFileSession( + const TRichYPath& richPath, + i64 cookieCount, + const TStartDistributedWriteFileOptions& options = {}) = 0; + + /// + /// @brief Initialize distributed table session and request cookies for participants. + /// + /// @see [YT doc](https://ytsaurus.tech/docs/en/api/commands.html#start_distributed_write_session) + virtual TDistributedWriteTableSessionWithCookies StartDistributedWriteTableSession( + const TRichYPath& richPath, + i64 cookieCount, + const TStartDistributedWriteTableOptions& options = {}) = 0; + + /// /// @brief Change properties of table. /// /// Allows to: @@ -580,14 +598,6 @@ public: /// Distributed table write API /// @{ - /// @brief Initialize distributed session and request cookies for participants. - /// - /// @see [YT doc](https://ytsaurus.tech/docs/en/api/commands.html#start_distributed_write_session) - virtual TDistributedWriteTableSessionWithCookies StartDistributedWriteTableSession( - const TRichYPath& richPath, - i64 cookieCount, - const TStartDistributedWriteTableOptions& options = {}) = 0; - /// @brief Ping distributed session to prolong its main transaction lifetime. /// /// @see [YT doc](https://ytsaurus.tech/docs/en/api/commands.html#ping_distributed_write_session) @@ -609,14 +619,6 @@ public: /// Distributed file write API /// @{ - /// @brief Initialize distributed session and request cookies for participants. - /// - /// @see [YT doc](https://ytsaurus.tech/docs/en/api/commands.html#start_distributed_write_file_session) - virtual TDistributedWriteFileSessionWithCookies StartDistributedWriteFileSession( - const TRichYPath& richPath, - i64 cookieCount, - const TStartDistributedWriteFileOptions& options = {}) = 0; - /// @brief Ping distributed session to prolong its main transaction lifetime. /// /// @see [YT doc](https://ytsaurus.tech/docs/en/api/commands.html#ping_distributed_write_file_session) diff --git a/yt/cpp/mapreduce/interface/raw_client.h b/yt/cpp/mapreduce/interface/raw_client.h index 23b311e457a..0c451951a07 100644 --- a/yt/cpp/mapreduce/interface/raw_client.h +++ b/yt/cpp/mapreduce/interface/raw_client.h @@ -338,6 +338,7 @@ public: virtual TDistributedWriteTableSessionWithCookies StartDistributedWriteTableSession( TMutationId& mutationId, + const TTransactionId& transactionId, const TRichYPath& richPath, i64 cookieCount, const TStartDistributedWriteTableOptions& options = {}) = 0; @@ -359,6 +360,7 @@ public: virtual TDistributedWriteFileSessionWithCookies StartDistributedWriteFileSession( TMutationId& mutationId, + const TTransactionId& transactionId, const TRichYPath& richPath, i64 cookieCount, const TStartDistributedWriteFileOptions& options = {}) = 0; |
