diff options
author | AlexSm <alex@ydb.tech> | 2024-01-11 14:49:03 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-01-11 14:49:03 +0100 |
commit | 2e180154bd6a38b90a128ba0463d0dd2706a5ccf (patch) | |
tree | 0e0890fa08e63af33c52c9b6eacee56d037a740b /yt/cpp/mapreduce/client | |
parent | 4366d88bef9360d9754e77eaa1f4a25d046a9cbd (diff) | |
download | ydb-2e180154bd6a38b90a128ba0463d0dd2706a5ccf.tar.gz |
Library import 7 (#937)
Diffstat (limited to 'yt/cpp/mapreduce/client')
-rw-r--r-- | yt/cpp/mapreduce/client/client.h | 2 | ||||
-rw-r--r-- | yt/cpp/mapreduce/client/operation.cpp | 18 | ||||
-rw-r--r-- | yt/cpp/mapreduce/client/retry_heavy_write_request.h | 4 | ||||
-rw-r--r-- | yt/cpp/mapreduce/client/retryful_writer.h | 2 | ||||
-rw-r--r-- | yt/cpp/mapreduce/client/structured_table_formats.cpp | 2 |
5 files changed, 14 insertions, 14 deletions
diff --git a/yt/cpp/mapreduce/client/client.h b/yt/cpp/mapreduce/client/client.h index 9bed0d7287..5de00285ef 100644 --- a/yt/cpp/mapreduce/client/client.h +++ b/yt/cpp/mapreduce/client/client.h @@ -388,7 +388,7 @@ public: const TNode::TListType& keys, const TDeleteRowsOptions& options) override; - void TrimRows( + void TrimRows( const TYPath& path, i64 tabletIndex, i64 rowCount, diff --git a/yt/cpp/mapreduce/client/operation.cpp b/yt/cpp/mapreduce/client/operation.cpp index 855e6e834c..ade0f339b7 100644 --- a/yt/cpp/mapreduce/client/operation.cpp +++ b/yt/cpp/mapreduce/client/operation.cpp @@ -364,9 +364,9 @@ TString GetJobStderrWithRetriesAndIgnoreErrors( options); } catch (const TErrorResponse& e) { YT_LOG_ERROR("Cannot get job stderr (OperationId: %v, JobId: %v, Error: %v)", - operationId, - jobId, - e.what()); + operationId, + jobId, + e.what()); } if (jobStderr.size() > stderrTailSize) { jobStderr = jobStderr.substr(jobStderr.size() - stderrTailSize, stderrTailSize); @@ -1605,12 +1605,12 @@ void ExecuteMapReduce( auto nodeReaderFormat = NodeReaderFormatFromHintAndGlobalConfig(spec.MapperFormatHints_); auto [inputFormat, inputFormatConfig] = formatBuilder.CreateFormat( - *mapper, - EIODirection::Input, - structuredInputs, - hints.InputFormatHints_, - nodeReaderFormat, - /* allowFormatFromTableAttribute */ true); + *mapper, + EIODirection::Input, + structuredInputs, + hints.InputFormatHints_, + nodeReaderFormat, + /* allowFormatFromTableAttribute */ true); auto [outputFormat, outputFormatConfig] = formatBuilder.CreateFormat( *mapper, diff --git a/yt/cpp/mapreduce/client/retry_heavy_write_request.h b/yt/cpp/mapreduce/client/retry_heavy_write_request.h index 853306ff42..052bbfb860 100644 --- a/yt/cpp/mapreduce/client/retry_heavy_write_request.h +++ b/yt/cpp/mapreduce/client/retry_heavy_write_request.h @@ -31,12 +31,12 @@ public: void Update(TStreamFactory streamFactory); void Finish(); - private: +private: void Retry(const std::function<void()>& function); void TryStartAttempt(); - private: +private: const TParameters Parameters_; const IRequestRetryPolicyPtr RequestRetryPolicy_; diff --git a/yt/cpp/mapreduce/client/retryful_writer.h b/yt/cpp/mapreduce/client/retryful_writer.h index 8c6de1c266..0b345daabf 100644 --- a/yt/cpp/mapreduce/client/retryful_writer.h +++ b/yt/cpp/mapreduce/client/retryful_writer.h @@ -77,7 +77,7 @@ public: size_t GetRetryBlockRemainingSize() const { - return (BufferSize_ > Buffer_.size()) ? (BufferSize_ - Buffer_.size()) : 0; + return (BufferSize_ > Buffer_.size()) ? (BufferSize_ - Buffer_.size()) : 0; } protected: diff --git a/yt/cpp/mapreduce/client/structured_table_formats.cpp b/yt/cpp/mapreduce/client/structured_table_formats.cpp index b0038f7386..6dba1e1435 100644 --- a/yt/cpp/mapreduce/client/structured_table_formats.cpp +++ b/yt/cpp/mapreduce/client/structured_table_formats.cpp @@ -431,7 +431,7 @@ std::pair<TFormat, TMaybe<TSmallJobFile>> TFormatBuilder::CreateNodeFormat( auto format = CreateSkiffFormat(skiffSchema); NYT::NDetail::ApplyFormatHints<TNode>(&format, formatHints); return { - CreateSkiffFormat(skiffSchema), + format, TSmallJobFile{ TString("skiff") + GetSuffix(direction), CreateSkiffConfig(skiffSchema) |