From afcb7a98ea319ebfe80a2f649f168443729c8faa Mon Sep 17 00:00:00 2001 From: apollo1321 Date: Fri, 28 Mar 2025 22:24:48 +0300 Subject: YT-10317: Support slicing jobs by compressed data size in ordered merge and map commit_hash:68852e1d05ac25a36f611cdd51f5cd4acfbe7135 --- yt/yt/client/api/rpc_proxy/client_impl.cpp | 2 ++ yt/yt/client/api/table_client.h | 3 +++ yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto | 3 +++ 3 files changed, 8 insertions(+) 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 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; } -- cgit v1.3