aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/client/operation.cpp
diff options
context:
space:
mode:
authorhiddenpath <hiddenpath@yandex-team.com>2025-01-15 23:25:11 +0300
committerhiddenpath <hiddenpath@yandex-team.com>2025-01-15 23:42:58 +0300
commit183b86950af6daa68f57eb29b6b8ef252d5b3a15 (patch)
treea69cd2da925c2c55c2df636c8cbe459bd4159536 /yt/cpp/mapreduce/client/operation.cpp
parentabccd55428243410fdc9ab1c84039549a6d3ae06 (diff)
downloadydb-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.cpp9
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_) {