diff options
| author | hiddenpath <hiddenpath@yandex-team.com> | 2025-01-15 23:25:11 +0300 |
|---|---|---|
| committer | hiddenpath <hiddenpath@yandex-team.com> | 2025-01-15 23:42:58 +0300 |
| commit | 183b86950af6daa68f57eb29b6b8ef252d5b3a15 (patch) | |
| tree | a69cd2da925c2c55c2df636c8cbe459bd4159536 /yt/cpp/mapreduce/client/structured_table_formats.cpp | |
| parent | abccd55428243410fdc9ab1c84039549a6d3ae06 (diff) | |
| download | ydb-183b86950af6daa68f57eb29b6b8ef252d5b3a15.tar.gz | |
YT-23616: Make BatchTransform implementation being common
commit_hash:4191c9aa7cde449475eddf88d8c04e1ebf0b8ad9
Diffstat (limited to 'yt/cpp/mapreduce/client/structured_table_formats.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/client/structured_table_formats.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/client/structured_table_formats.cpp b/yt/cpp/mapreduce/client/structured_table_formats.cpp index 72b76e6b80..3d95f93027 100644 --- a/yt/cpp/mapreduce/client/structured_table_formats.cpp +++ b/yt/cpp/mapreduce/client/structured_table_formats.cpp @@ -121,6 +121,7 @@ namespace NDetail { //////////////////////////////////////////////////////////////////////////////// NSkiff::TSkiffSchemaPtr TryCreateSkiffSchema( + const IRawClientPtr& rawClient, const TClientContext& context, const IClientRetryPolicyPtr& clientRetryPolicy, const TTransactionId& transactionId, @@ -135,6 +136,7 @@ NSkiff::TSkiffSchemaPtr TryCreateSkiffSchema( return nullptr; } return CreateSkiffSchemaIfNecessary( + rawClient, context, clientRetryPolicy, transactionId, @@ -434,6 +436,7 @@ std::pair<TFormat, TMaybe<TSmallJobFile>> TFormatBuilder::CreateNodeFormat( tableList.emplace_back(*table.RichYPath); } skiffSchema = TryCreateSkiffSchema( + RawClient_, Context_, ClientRetryPolicy_, TransactionId_, |