summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/http_client/raw_client.cpp
diff options
context:
space:
mode:
authorhiddenpath <[email protected]>2025-05-30 14:23:32 +0300
committerhiddenpath <[email protected]>2025-05-30 14:52:12 +0300
commit4850e38fc581e776c4b74166b24cc67a65726ae1 (patch)
treeb8b7bf6cb36e2d29b2283cdd3fe438cfbe96a79b /yt/cpp/mapreduce/http_client/raw_client.cpp
parentaa5b65fb974e9de8da3dfd1716808817e83c9e6b (diff)
Introduce suppress access tracking options
commit_hash:1b44475c0447374091b3f13cd7e2126757874ebb
Diffstat (limited to 'yt/cpp/mapreduce/http_client/raw_client.cpp')
-rw-r--r--yt/cpp/mapreduce/http_client/raw_client.cpp22
1 files changed, 3 insertions, 19 deletions
diff --git a/yt/cpp/mapreduce/http_client/raw_client.cpp b/yt/cpp/mapreduce/http_client/raw_client.cpp
index cb5a852b176..f50b239c2aa 100644
--- a/yt/cpp/mapreduce/http_client/raw_client.cpp
+++ b/yt/cpp/mapreduce/http_client/raw_client.cpp
@@ -569,10 +569,10 @@ std::unique_ptr<IInputStream> THttpRawClient::ReadFile(
{
TMutationId mutationId;
THttpHeader header("GET", GetReadFileCommand(Context_.Config->ApiVersion));
- header.AddTransactionId(transactionId);
header.SetOutputFormat(TMaybe<TFormat>()); // Binary format
- header.MergeParameters(FormIORequestParameters(path, options));
header.SetResponseCompression(ToString(Context_.Config->AcceptEncoding));
+ header.MergeParameters(NRawClient::SerializeParamsForReadFile(transactionId, options));
+ header.MergeParameters(FormIORequestParameters(path, options));
TRequestConfig config;
config.IsHeavy = true;
@@ -740,23 +740,7 @@ TNode::TListType THttpRawClient::SelectRows(
THttpHeader header("GET", "select_rows");
header.SetInputFormat(TFormat::YsonBinary());
header.SetOutputFormat(TFormat::YsonBinary());
-
- header.MergeParameters(BuildYsonNodeFluently().BeginMap()
- .Item("query").Value(query)
- .DoIf(options.Timeout_.Defined(), [&] (TFluentMap fluent) {
- fluent.Item("timeout").Value(static_cast<i64>(options.Timeout_->MilliSeconds()));
- })
- .DoIf(options.InputRowLimit_.Defined(), [&] (TFluentMap fluent) {
- fluent.Item("input_row_limit").Value(*options.InputRowLimit_);
- })
- .DoIf(options.OutputRowLimit_.Defined(), [&] (TFluentMap fluent) {
- fluent.Item("output_row_limit").Value(*options.OutputRowLimit_);
- })
- .Item("range_expansion_limit").Value(options.RangeExpansionLimit_)
- .Item("fail_on_incomplete_result").Value(options.FailOnIncompleteResult_)
- .Item("verbose_logging").Value(options.VerboseLogging_)
- .Item("enable_code_cache").Value(options.EnableCodeCache_)
- .EndMap());
+ header.MergeParameters(NRawClient::SerializeParamsForSelectRows(query, options));
TRequestConfig config;
config.IsHeavy = true;