diff options
| author | apollo1321 <[email protected]> | 2025-03-28 22:24:48 +0300 |
|---|---|---|
| committer | apollo1321 <[email protected]> | 2025-03-28 22:51:55 +0300 |
| commit | afcb7a98ea319ebfe80a2f649f168443729c8faa (patch) | |
| tree | 060b056be9ea1b316838c7691bd8604572521d4e | |
| parent | b60cb8f5ce78ae5f63304a534278e124d31398b0 (diff) | |
YT-10317: Support slicing jobs by compressed data size in ordered merge and map
commit_hash:68852e1d05ac25a36f611cdd51f5cd4acfbe7135
| -rw-r--r-- | yt/yt/client/api/rpc_proxy/client_impl.cpp | 2 | ||||
| -rw-r--r-- | yt/yt/client/api/table_client.h | 3 | ||||
| -rw-r--r-- | yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto | 3 |
3 files changed, 8 insertions, 0 deletions
diff --git a/yt/yt/client/api/rpc_proxy/client_impl.cpp b/yt/yt/client/api/rpc_proxy/client_impl.cpp index a5d3dc42498..f0a36ee11b0 100644 --- a/yt/yt/client/api/rpc_proxy/client_impl.cpp +++ b/yt/yt/client/api/rpc_proxy/client_impl.cpp @@ -1741,6 +1741,8 @@ TFuture<NApi::TMultiTablePartitions> TClient::PartitionTables( req->set_enable_key_guarantee(options.EnableKeyGuarantee); req->set_enable_cookies(options.EnableCookies); + req->set_use_new_slicing_implementation_in_ordered_pool(options.UseNewSlicingImplementationInOrderedPool); + ToProto(req->mutable_transactional_options(), options); return req->Invoke().Apply(BIND([] (const TApiServiceProxy::TRspPartitionTablesPtr& rsp) { diff --git a/yt/yt/client/api/table_client.h b/yt/yt/client/api/table_client.h index c6faa288fad..bbff942011b 100644 --- a/yt/yt/client/api/table_client.h +++ b/yt/yt/client/api/table_client.h @@ -319,6 +319,9 @@ struct TPartitionTablesOptions //! Whether to return cookies that can be fed to CreateTablePartitionReader. bool EnableCookies = false; + + //! COMPAT(apollo1321): remove in 25.2 release. + bool UseNewSlicingImplementationInOrderedPool = true; }; struct TReadTablePartitionOptions diff --git a/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto b/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto index d121f2e0794..e0df5206e7b 100644 --- a/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto +++ b/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto @@ -2154,6 +2154,9 @@ message TReqPartitionTables optional bool enable_cookies = 10; + // COMPAT(apollo1321): Remove in 25.2 release. + optional bool use_new_slicing_implementation_in_ordered_pool = 11 [default=true]; + optional TTransactionalOptions transactional_options = 100; } |