diff options
| author | hiddenpath <[email protected]> | 2025-05-30 14:23:32 +0300 |
|---|---|---|
| committer | hiddenpath <[email protected]> | 2025-05-30 14:52:12 +0300 |
| commit | 4850e38fc581e776c4b74166b24cc67a65726ae1 (patch) | |
| tree | b8b7bf6cb36e2d29b2283cdd3fe438cfbe96a79b /yt/cpp/mapreduce/http_client/raw_client.cpp | |
| parent | aa5b65fb974e9de8da3dfd1716808817e83c9e6b (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.cpp | 22 |
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; |
