diff options
author | hiddenpath <hiddenpath@yandex-team.com> | 2025-01-16 00:49:07 +0300 |
---|---|---|
committer | hiddenpath <hiddenpath@yandex-team.com> | 2025-01-16 01:07:01 +0300 |
commit | 8dff5c10763551a5b2e82294518d7d95d68bec23 (patch) | |
tree | 2cebe415c5a7b7c04b979964c48ec4d36c613d01 /yt/cpp/mapreduce/client/structured_table_formats.cpp | |
parent | 0395c5087038d4d95d8f64c67e458add6ac040fd (diff) | |
download | ydb-8dff5c10763551a5b2e82294518d7d95d68bec23.tar.gz |
YT-23616: Make implementation of CanonizeYPath method being common
commit_hash:7f3ecc44b4299acc4fc7b0f463eceac61d0b0156
Diffstat (limited to 'yt/cpp/mapreduce/client/structured_table_formats.cpp')
-rw-r--r-- | yt/cpp/mapreduce/client/structured_table_formats.cpp | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/yt/cpp/mapreduce/client/structured_table_formats.cpp b/yt/cpp/mapreduce/client/structured_table_formats.cpp index 3d95f93027..9da31dcf14 100644 --- a/yt/cpp/mapreduce/client/structured_table_formats.cpp +++ b/yt/cpp/mapreduce/client/structured_table_formats.cpp @@ -122,8 +122,6 @@ namespace NDetail { NSkiff::TSkiffSchemaPtr TryCreateSkiffSchema( const IRawClientPtr& rawClient, - const TClientContext& context, - const IClientRetryPolicyPtr& clientRetryPolicy, const TTransactionId& transactionId, const TVector<TRichYPath>& tables, const TOperationOptions& options, @@ -137,8 +135,6 @@ NSkiff::TSkiffSchemaPtr TryCreateSkiffSchema( } return CreateSkiffSchemaIfNecessary( rawClient, - context, - clientRetryPolicy, transactionId, nodeReaderFormat, tables, @@ -214,14 +210,14 @@ TStructuredJobTableList ToStructuredJobTableList(const TVector<TStructuredTableP return result; } -TStructuredJobTableList CanonizeStructuredTableList(const TClientContext& context, const TVector<TStructuredTablePath>& tableList) +TStructuredJobTableList CanonizeStructuredTableList(const IRawClientPtr& rawClient, const TVector<TStructuredTablePath>& tableList) { TVector<TRichYPath> toCanonize; toCanonize.reserve(tableList.size()); for (const auto& table : tableList) { toCanonize.emplace_back(table.RichYPath); } - const auto canonized = NRawClient::CanonizeYPaths(/* retryPolicy */ nullptr, context, toCanonize); + const auto canonized = NRawClient::CanonizeYPaths(rawClient, toCanonize); Y_ABORT_UNLESS(canonized.size() == tableList.size()); TStructuredJobTableList result; @@ -437,8 +433,6 @@ std::pair<TFormat, TMaybe<TSmallJobFile>> TFormatBuilder::CreateNodeFormat( } skiffSchema = TryCreateSkiffSchema( RawClient_, - Context_, - ClientRetryPolicy_, TransactionId_, tableList, OperationOptions_, |