aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/client/structured_table_formats.cpp
diff options
context:
space:
mode:
authorhiddenpath <hiddenpath@yandex-team.com>2025-01-16 00:49:07 +0300
committerhiddenpath <hiddenpath@yandex-team.com>2025-01-16 01:07:01 +0300
commit8dff5c10763551a5b2e82294518d7d95d68bec23 (patch)
tree2cebe415c5a7b7c04b979964c48ec4d36c613d01 /yt/cpp/mapreduce/client/structured_table_formats.cpp
parent0395c5087038d4d95d8f64c67e458add6ac040fd (diff)
downloadydb-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.cpp10
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_,