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/operation.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/operation.cpp')
-rw-r--r-- | yt/cpp/mapreduce/client/operation.cpp | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/yt/cpp/mapreduce/client/operation.cpp b/yt/cpp/mapreduce/client/operation.cpp index 5caf302358..bfb56b4a73 100644 --- a/yt/cpp/mapreduce/client/operation.cpp +++ b/yt/cpp/mapreduce/client/operation.cpp @@ -225,11 +225,10 @@ TStructuredJobTableList ApplyProtobufColumnFilters( } auto isDynamic = NRawClient::BatchTransform( - CreateDefaultRequestRetryPolicy(preparer.GetContext().Config), - preparer.GetContext(), + preparer.GetClient()->GetRawClient(), tableList, - [&] (IRawBatchRequest& batch, const auto& table) { - return batch.Get(preparer.GetTransactionId(), table.RichYPath->Path_ + "/@dynamic", TGetOptions()); + [&] (IRawBatchRequestPtr batch, const auto& table) { + return batch->Get(preparer.GetTransactionId(), table.RichYPath->Path_ + "/@dynamic", TGetOptions()); }); auto newTableList = tableList; @@ -642,7 +641,7 @@ TNode BuildAutoMergeSpec(const TAutoMergeSpec& options) return result; } -TNode BuildJobProfilerSpec(const TJobProfilerSpec& profilerSpec) +[[maybe_unused]] TNode BuildJobProfilerSpec(const TJobProfilerSpec& profilerSpec) { TNode result; if (profilerSpec.ProfilingBinary_) { |