summaryrefslogtreecommitdiffstats
path: root/yt/cpp
diff options
context:
space:
mode:
authorpavook <[email protected]>2024-08-22 16:26:27 +0300
committerpavook <[email protected]>2024-08-22 16:39:20 +0300
commit8520e043f2e12acdfd39d971ebeeacbe9e5ac3ca (patch)
tree55e2c5a3efebd951a92445ed5c7327c86479f655 /yt/cpp
parentf9fbb65f64b68c5de5cf257c04e06ac6aeaeb1e8 (diff)
GLOBAL OTBIVKA FIX ୧༼ಠ益ಠ༽୨
Make all "otbivka" exactly 80 symbols. Command: ```bash sed -i 's#^//////////////\+$#////////////////////////////////////////////////////////////////////////////////#g' $(find yt \( -name '*.cpp' -or -name '*.h' -or -name '*.proto' \) -not -path 'yt/yt/experiments/private/tabletvis/imgui/*') ``` 30a0ba9f42ba1909d3cee11fe12bba14c7c8b039
Diffstat (limited to 'yt/cpp')
-rw-r--r--yt/cpp/mapreduce/client/batch_request_impl.cpp2
-rw-r--r--yt/cpp/mapreduce/client/operation.cpp2
-rw-r--r--yt/cpp/mapreduce/client/retry_heavy_write_request.h4
-rw-r--r--yt/cpp/mapreduce/http/context.h2
-rw-r--r--yt/cpp/mapreduce/http/helpers.cpp4
-rw-r--r--yt/cpp/mapreduce/http/helpers.h4
-rw-r--r--yt/cpp/mapreduce/http/http.h2
-rw-r--r--yt/cpp/mapreduce/http/http_client.cpp8
-rw-r--r--yt/cpp/mapreduce/http/http_client.h8
-rw-r--r--yt/cpp/mapreduce/http/requests.h2
-rw-r--r--yt/cpp/mapreduce/http/retry_request.cpp4
-rw-r--r--yt/cpp/mapreduce/http/retry_request.h8
-rw-r--r--yt/cpp/mapreduce/interface/batch_request.h4
-rw-r--r--yt/cpp/mapreduce/interface/errors.cpp6
-rw-r--r--yt/cpp/mapreduce/interface/io.h2
-rw-r--r--yt/cpp/mapreduce/interface/job_counters.cpp8
-rw-r--r--yt/cpp/mapreduce/interface/job_counters.h2
-rw-r--r--yt/cpp/mapreduce/interface/job_statistics.cpp16
-rw-r--r--yt/cpp/mapreduce/interface/job_statistics.h12
-rw-r--r--yt/cpp/mapreduce/interface/operation.h10
-rw-r--r--yt/cpp/mapreduce/interface/ut/operation_ut.cpp6
-rw-r--r--yt/cpp/mapreduce/io/ut/end_of_stream_ut.cpp6
-rw-r--r--yt/cpp/mapreduce/io/ut/readers_ut.cpp6
-rw-r--r--yt/cpp/mapreduce/io/ut/yamr_table_reader_ut.cpp4
-rw-r--r--yt/cpp/mapreduce/io/yamr_table_reader.cpp4
-rw-r--r--yt/cpp/mapreduce/raw_client/raw_batch_request.cpp30
-rw-r--r--yt/cpp/mapreduce/raw_client/raw_requests.cpp2
-rw-r--r--yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp4
-rw-r--r--yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h4
29 files changed, 88 insertions, 88 deletions
diff --git a/yt/cpp/mapreduce/client/batch_request_impl.cpp b/yt/cpp/mapreduce/client/batch_request_impl.cpp
index 6afa5665f12..08ffec2bfcd 100644
--- a/yt/cpp/mapreduce/client/batch_request_impl.cpp
+++ b/yt/cpp/mapreduce/client/batch_request_impl.cpp
@@ -32,7 +32,7 @@ using ::NThreading::TFuture;
using ::NThreading::TPromise;
using ::NThreading::NewPromise;
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TBatchRequest::TBatchRequest(const TTransactionId& defaultTransaction, ::TIntrusivePtr<TClient> client)
: DefaultTransaction_(defaultTransaction)
diff --git a/yt/cpp/mapreduce/client/operation.cpp b/yt/cpp/mapreduce/client/operation.cpp
index f4df2e2dd72..0d5e8922148 100644
--- a/yt/cpp/mapreduce/client/operation.cpp
+++ b/yt/cpp/mapreduce/client/operation.cpp
@@ -344,7 +344,7 @@ TSimpleOperationIo CreateSimpleOperationIo(
};
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TString GetJobStderrWithRetriesAndIgnoreErrors(
const IRequestRetryPolicyPtr& retryPolicy,
diff --git a/yt/cpp/mapreduce/client/retry_heavy_write_request.h b/yt/cpp/mapreduce/client/retry_heavy_write_request.h
index 052bbfb860b..b3a6ec0f7c2 100644
--- a/yt/cpp/mapreduce/client/retry_heavy_write_request.h
+++ b/yt/cpp/mapreduce/client/retry_heavy_write_request.h
@@ -8,7 +8,7 @@
namespace NYT {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class THeavyRequestRetrier
{
@@ -52,7 +52,7 @@ private:
TStreamFactory StreamFactory_;
};
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void RetryHeavyWriteRequest(
const IClientRetryPolicyPtr& clientRetryPolicy,
diff --git a/yt/cpp/mapreduce/http/context.h b/yt/cpp/mapreduce/http/context.h
index 3bae208279b..f50c1b97326 100644
--- a/yt/cpp/mapreduce/http/context.h
+++ b/yt/cpp/mapreduce/http/context.h
@@ -9,7 +9,7 @@
namespace NYT {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TClientContext
{
diff --git a/yt/cpp/mapreduce/http/helpers.cpp b/yt/cpp/mapreduce/http/helpers.cpp
index 18f74b59584..0e34610ef1a 100644
--- a/yt/cpp/mapreduce/http/helpers.cpp
+++ b/yt/cpp/mapreduce/http/helpers.cpp
@@ -9,7 +9,7 @@
namespace NYT {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TString CreateHostNameWithPort(const TString& hostName, const TClientContext& context)
{
@@ -100,6 +100,6 @@ void LogRequest(const THttpHeader& header, const TString& url, bool includeParam
GetLoggedAttributes(header, url, includeParameters, Max<size_t>()));
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/cpp/mapreduce/http/helpers.h b/yt/cpp/mapreduce/http/helpers.h
index 82ef799ca1f..474813674ef 100644
--- a/yt/cpp/mapreduce/http/helpers.h
+++ b/yt/cpp/mapreduce/http/helpers.h
@@ -8,7 +8,7 @@
namespace NYT {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TString CreateHostNameWithPort(const TString& name, const TClientContext& context);
@@ -24,6 +24,6 @@ TString GetLoggedAttributes(const THttpHeader& header, const TString& url, bool
void LogRequest(const THttpHeader& header, const TString& url, bool includeParameters, const TString& requestId, const TString& hostName);
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/cpp/mapreduce/http/http.h b/yt/cpp/mapreduce/http/http.h
index 8bfa00de1dc..95595959ad4 100644
--- a/yt/cpp/mapreduce/http/http.h
+++ b/yt/cpp/mapreduce/http/http.h
@@ -31,7 +31,7 @@ struct THeadersPtrWrapper;
} // NHttp
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
enum class EFrameType
{
diff --git a/yt/cpp/mapreduce/http/http_client.cpp b/yt/cpp/mapreduce/http/http_client.cpp
index 6dc24c6ef2f..305d95b06cc 100644
--- a/yt/cpp/mapreduce/http/http_client.cpp
+++ b/yt/cpp/mapreduce/http/http_client.cpp
@@ -102,7 +102,7 @@ void CheckErrorResponse(const TString& hostName, const TString& requestId, const
} // namespace
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TDefaultHttpResponse
: public IHttpResponse
@@ -188,7 +188,7 @@ public:
}
};
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TCoreRequestContext
{
@@ -586,7 +586,7 @@ private:
NHttp::IClientPtr Client_;
};
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
IHttpClientPtr CreateDefaultHttpClient()
{
@@ -598,6 +598,6 @@ IHttpClientPtr CreateCoreHttpClient(bool useTLS, const TConfigPtr& config)
return std::make_shared<TCoreHttpClient>(useTLS, config);
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NHttpClient
diff --git a/yt/cpp/mapreduce/http/http_client.h b/yt/cpp/mapreduce/http/http_client.h
index 859f0423cb4..97321c4c9d3 100644
--- a/yt/cpp/mapreduce/http/http_client.h
+++ b/yt/cpp/mapreduce/http/http_client.h
@@ -15,14 +15,14 @@
namespace NYT::NHttpClient {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct THttpConfig
{
TDuration SocketTimeout = TDuration::Zero();
};
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class IHttpResponse
{
@@ -65,12 +65,12 @@ public:
}
};
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
IHttpClientPtr CreateDefaultHttpClient();
IHttpClientPtr CreateCoreHttpClient(bool useTLS, const TConfigPtr& config);
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NHttpClient
diff --git a/yt/cpp/mapreduce/http/requests.h b/yt/cpp/mapreduce/http/requests.h
index 2c692475d1c..a21cff53600 100644
--- a/yt/cpp/mapreduce/http/requests.h
+++ b/yt/cpp/mapreduce/http/requests.h
@@ -8,7 +8,7 @@
namespace NYT {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
bool ParseBoolFromResponse(const TString& response);
diff --git a/yt/cpp/mapreduce/http/retry_request.cpp b/yt/cpp/mapreduce/http/retry_request.cpp
index 63a36c2f78a..307e310b5b9 100644
--- a/yt/cpp/mapreduce/http/retry_request.cpp
+++ b/yt/cpp/mapreduce/http/retry_request.cpp
@@ -18,7 +18,7 @@
namespace NYT {
namespace NDetail {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static TResponseInfo Request(
const TClientContext& context,
@@ -147,7 +147,7 @@ TResponseInfo RetryRequestWithPolicy(
Y_ABORT("Retries must have either succeeded or thrown an exception");
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NDetail
} // namespace NYT
diff --git a/yt/cpp/mapreduce/http/retry_request.h b/yt/cpp/mapreduce/http/retry_request.h
index 2210e318f10..a6007d6eae3 100644
--- a/yt/cpp/mapreduce/http/retry_request.h
+++ b/yt/cpp/mapreduce/http/retry_request.h
@@ -13,7 +13,7 @@
namespace NYT::NDetail {
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TResponseInfo
{
@@ -22,7 +22,7 @@ struct TResponseInfo
int HttpCode = 0;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TRequestConfig
{
@@ -30,7 +30,7 @@ struct TRequestConfig
bool IsHeavy = false;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
// Retry request with given `header' and `body' using `retryPolicy'.
// If `retryPolicy == nullptr' use default, currently `TAttemptLimitedRetryPolicy(TConfig::Get()->RetryCount)`.
@@ -47,6 +47,6 @@ TResponseInfo RequestWithoutRetry(
TMaybe<TStringBuf> body = {},
const TRequestConfig& config = TRequestConfig());
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NDetail
diff --git a/yt/cpp/mapreduce/interface/batch_request.h b/yt/cpp/mapreduce/interface/batch_request.h
index 3ea28f76fd5..8056f8a1edd 100644
--- a/yt/cpp/mapreduce/interface/batch_request.h
+++ b/yt/cpp/mapreduce/interface/batch_request.h
@@ -9,7 +9,7 @@
namespace NYT {
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
/// Helper base of @ref NYT::IBatchRequest holding most of useful methods.
class IBatchRequestBase
@@ -217,6 +217,6 @@ public:
virtual void ExecuteBatch(const TExecuteBatchOptions& options = TExecuteBatchOptions()) = 0;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/cpp/mapreduce/interface/errors.cpp b/yt/cpp/mapreduce/interface/errors.cpp
index 49a7c7cfc10..ef3d2db4a31 100644
--- a/yt/cpp/mapreduce/interface/errors.cpp
+++ b/yt/cpp/mapreduce/interface/errors.cpp
@@ -16,7 +16,7 @@ namespace NYT {
using namespace NJson;
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static void WriteErrorDescription(const TYtError& error, IOutputStream* out)
{
@@ -107,7 +107,7 @@ static TString DumpJobInfoForException(const TOperationId& operationId, const TV
return output;
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TYtError::TYtError()
: Code_(0)
@@ -396,7 +396,7 @@ void TErrorResponse::Setup()
*this << Error_.FullDescription();
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TOperationFailedError::TOperationFailedError(
EState state,
diff --git a/yt/cpp/mapreduce/interface/io.h b/yt/cpp/mapreduce/interface/io.h
index 1d7f5375a22..becde0def2f 100644
--- a/yt/cpp/mapreduce/interface/io.h
+++ b/yt/cpp/mapreduce/interface/io.h
@@ -101,7 +101,7 @@ class TIOException
: public yexception
{ };
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
/// Interface representing YT file reader.
class IFileReader
diff --git a/yt/cpp/mapreduce/interface/job_counters.cpp b/yt/cpp/mapreduce/interface/job_counters.cpp
index 717982e216a..2d0284e2b1b 100644
--- a/yt/cpp/mapreduce/interface/job_counters.cpp
+++ b/yt/cpp/mapreduce/interface/job_counters.cpp
@@ -2,7 +2,7 @@
namespace NYT {
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
namespace {
ui64 CountTotal(const TNode& data)
@@ -31,7 +31,7 @@ namespace {
}
} // namespace
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TJobCounter::TJobCounter(TNode data)
: Data_(std::move(data))
@@ -58,7 +58,7 @@ ui64 TJobCounter::GetValue(const TStringBuf key) const
return 0;
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TJobCounters::TJobCounters(const TNode& counters)
: Total_(0)
@@ -159,6 +159,6 @@ ui64 TJobCounters::GetTotal() const
return Total_;
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/cpp/mapreduce/interface/job_counters.h b/yt/cpp/mapreduce/interface/job_counters.h
index 573cbe47844..24efddd7d0b 100644
--- a/yt/cpp/mapreduce/interface/job_counters.h
+++ b/yt/cpp/mapreduce/interface/job_counters.h
@@ -69,6 +69,6 @@ private:
TJobCounter Blocked_;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/cpp/mapreduce/interface/job_statistics.cpp b/yt/cpp/mapreduce/interface/job_statistics.cpp
index 4ff8dde3cca..0ee952f510c 100644
--- a/yt/cpp/mapreduce/interface/job_statistics.cpp
+++ b/yt/cpp/mapreduce/interface/job_statistics.cpp
@@ -17,7 +17,7 @@
namespace NYT {
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
template <>
i64 ConvertJobStatisticsEntry(i64 value)
@@ -31,7 +31,7 @@ TDuration ConvertJobStatisticsEntry(i64 value)
return TDuration::MilliSeconds(value);
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static TTaskName JobTypeToTaskName(EJobType jobType)
{
@@ -55,7 +55,7 @@ static TTaskName FixTaskName(TString taskName)
return taskName;
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TJobStatistics::TData
: public TThrRefBase
@@ -140,7 +140,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TJobStatistics::TFilter
: public TThrRefBase
@@ -149,7 +149,7 @@ struct TJobStatistics::TFilter
TVector<EJobState> JobStateFilter = {EJobState::Completed};
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
const TString TJobStatistics::CustomStatisticsNamePrefix_ = "custom/";
@@ -293,7 +293,7 @@ TMaybe<TJobStatistics::TDataEntry> TJobStatistics::GetStatisticsImpl(TStringBuf
return result;
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
namespace {
@@ -340,7 +340,7 @@ void WriteCustomStatisticsAny(TStringBuf path, const T& value)
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void WriteCustomStatistics(const TNode& statistics)
{
@@ -356,6 +356,6 @@ void WriteCustomStatistics(TStringBuf path, i64 value)
void FlushCustomStatisticsStream() {
GetStatisticsStream()->Flush();
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/cpp/mapreduce/interface/job_statistics.h b/yt/cpp/mapreduce/interface/job_statistics.h
index 4582d9e872e..a41b48d5c66 100644
--- a/yt/cpp/mapreduce/interface/job_statistics.h
+++ b/yt/cpp/mapreduce/interface/job_statistics.h
@@ -16,7 +16,7 @@
namespace NYT {
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
///
/// @brief Convert i64 representation of statistics to other type.
@@ -28,7 +28,7 @@ namespace NYT {
template <typename T>
T ConvertJobStatisticsEntry(i64 value);
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
/// Class representing a collection of job statistics.
class TJobStatistics
@@ -160,7 +160,7 @@ private:
friend class TJobStatisticsEntry;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
/// Class representing single statistic.
template <typename T>
@@ -225,7 +225,7 @@ private:
friend class TJobStatistics;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
template <typename T>
TJobStatisticsEntry<T> TJobStatistics::GetStatisticsAs(TStringBuf name) const
@@ -239,7 +239,7 @@ TJobStatisticsEntry<T> TJobStatistics::GetCustomStatisticsAs(TStringBuf name) co
return TJobStatisticsEntry<T>(GetStatisticsImpl(CustomStatisticsNamePrefix_ + name));
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
///
/// @brief Write [custom statistics](https://ytsaurus.tech/docs/en/user-guide/data-processing/operations/jobs#user_stats).
@@ -263,6 +263,6 @@ void WriteCustomStatistics(const TNode& statistics);
/// @brief Flush [custom statistics stream](https://ytsaurus.tech/docs/en/user-guide/data-processing/operations/jobs#user_stats)
///
void FlushCustomStatisticsStream();
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/cpp/mapreduce/interface/operation.h b/yt/cpp/mapreduce/interface/operation.h
index 76b67138a32..9e17ca7e905 100644
--- a/yt/cpp/mapreduce/interface/operation.h
+++ b/yt/cpp/mapreduce/interface/operation.h
@@ -86,7 +86,7 @@ TStructuredTablePath Structured(TRichYPath richYPath);
template <typename TRow>
TTableStructure StructuredTableDescription();
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
/// Tag class marking that row stream is empty.
struct TVoidStructuredRowStream
@@ -117,7 +117,7 @@ using TStructuredRowStreamDescription = std::variant<
TProtobufStructuredRowStream
>;
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
/// Tag class marking that current binary should be used in operation.
struct TJobBinaryDefault
@@ -710,7 +710,7 @@ struct TJobProfilerSpec
FLUENT_FIELD_OPTION(int, SamplingFrequency);
};
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
/// @brief Specification of a disk that will be available in job.
///
@@ -2981,7 +2981,7 @@ struct TListJobsResult
TMaybe<i64> ArchiveJobCount;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
///
/// @brief Options for @ref NYT::IClient::GetJob.
@@ -3019,7 +3019,7 @@ struct TGetJobStderrOptions
/// @endcond
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
///
/// @brief Options for @ref NYT::IOperation::GetFailedJobInfo.
diff --git a/yt/cpp/mapreduce/interface/ut/operation_ut.cpp b/yt/cpp/mapreduce/interface/ut/operation_ut.cpp
index 81d03d06186..b28a33142a1 100644
--- a/yt/cpp/mapreduce/interface/ut/operation_ut.cpp
+++ b/yt/cpp/mapreduce/interface/ut/operation_ut.cpp
@@ -14,7 +14,7 @@
using namespace NYT;
using namespace NYT::NUnitTesting;
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TDummyInferenceContext
: public IOperationPreparationContext
@@ -62,7 +62,7 @@ private:
TVector<TTableSchema> InputSchemas_;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TEST(TPrepareOperationTest, BasicSchemas)
{
@@ -269,4 +269,4 @@ TEST(TPrepareOperationTest, Bug_r7349102)
builder.Finish();
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/cpp/mapreduce/io/ut/end_of_stream_ut.cpp b/yt/cpp/mapreduce/io/ut/end_of_stream_ut.cpp
index 3642aa1e45c..449c966a3ba 100644
--- a/yt/cpp/mapreduce/io/ut/end_of_stream_ut.cpp
+++ b/yt/cpp/mapreduce/io/ut/end_of_stream_ut.cpp
@@ -4,7 +4,7 @@
using namespace NYT;
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TStringRawTableReader
: public TRawTableReader
@@ -39,7 +39,7 @@ private:
TStringStream Stream_;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TEndOfStreamTest
: public ::testing::TestWithParam<bool>
@@ -91,4 +91,4 @@ TEST_P(TEndOfStreamTest, Eos)
INSTANTIATE_TEST_SUITE_P(WithEos, TEndOfStreamTest, ::testing::Values(true));
INSTANTIATE_TEST_SUITE_P(WithoutEos, TEndOfStreamTest, ::testing::Values(false));
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/cpp/mapreduce/io/ut/readers_ut.cpp b/yt/cpp/mapreduce/io/ut/readers_ut.cpp
index 5068dbb6bc1..5f4c71b6f44 100644
--- a/yt/cpp/mapreduce/io/ut/readers_ut.cpp
+++ b/yt/cpp/mapreduce/io/ut/readers_ut.cpp
@@ -17,7 +17,7 @@ using namespace NYT;
using namespace NYT::NDetail;
using namespace NSkiff;
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TRetryEmulatingRawTableReader
: public TRawTableReader
@@ -73,7 +73,7 @@ private:
int DoReadCallCount_ = 0;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TEST(TReadersTest, YsonGood)
{
@@ -229,4 +229,4 @@ TEST(TReadersTest, ProtobufBad)
EXPECT_THROW(TLenvalProtoTableReader(proxy, { NYT::NTesting::TRow::descriptor() }).ReadRow(&row), yexception);
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/cpp/mapreduce/io/ut/yamr_table_reader_ut.cpp b/yt/cpp/mapreduce/io/ut/yamr_table_reader_ut.cpp
index d55a28b3e4e..fc20be017f9 100644
--- a/yt/cpp/mapreduce/io/ut/yamr_table_reader_ut.cpp
+++ b/yt/cpp/mapreduce/io/ut/yamr_table_reader_ut.cpp
@@ -10,7 +10,7 @@ void Out<std::tuple<TString, TString, TString>>(IOutputStream& out, const std::t
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TRowCollection
{
@@ -182,4 +182,4 @@ TEST(TYamrTableReaderTest, TestSkipRetry)
}
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/cpp/mapreduce/io/yamr_table_reader.cpp b/yt/cpp/mapreduce/io/yamr_table_reader.cpp
index 55f270a6b66..cb987674495 100644
--- a/yt/cpp/mapreduce/io/yamr_table_reader.cpp
+++ b/yt/cpp/mapreduce/io/yamr_table_reader.cpp
@@ -4,7 +4,7 @@
#include <yt/cpp/mapreduce/common/retry_lib.h>
#include <yt/cpp/mapreduce/raw_client/raw_requests.h>
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static void CheckedSkip(IInputStream* input, size_t byteCount)
{
@@ -12,7 +12,7 @@ static void CheckedSkip(IInputStream* input, size_t byteCount)
Y_ENSURE(skipped == byteCount, "Premature end of YaMR stream");
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
namespace NYT {
diff --git a/yt/cpp/mapreduce/raw_client/raw_batch_request.cpp b/yt/cpp/mapreduce/raw_client/raw_batch_request.cpp
index 4e609590590..1bd9532e4ca 100644
--- a/yt/cpp/mapreduce/raw_client/raw_batch_request.cpp
+++ b/yt/cpp/mapreduce/raw_client/raw_batch_request.cpp
@@ -28,7 +28,7 @@ using NThreading::TFuture;
using NThreading::TPromise;
using NThreading::NewPromise;
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static TString RequestInfo(const TNode& request)
{
@@ -58,7 +58,7 @@ static void EnsureType(const TMaybe<TNode>& node, TNode::EType type)
EnsureType(*node, type);
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
template <typename TReturnType>
class TResponseParserBase
@@ -86,7 +86,7 @@ protected:
TPromise<TReturnType> Result_;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TGetResponseParser
@@ -100,7 +100,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TVoidResponseParser
: public TResponseParserBase<void>
@@ -113,7 +113,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TListResponseParser
: public TResponseParserBase<TNode::TListType>
@@ -126,7 +126,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TExistsResponseParser
: public TResponseParserBase<bool>
@@ -139,7 +139,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TGuidResponseParser
: public TResponseParserBase<TGUID>
@@ -152,7 +152,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TCanonizeYPathResponseParser
: public TResponseParserBase<TRichYPath>
@@ -181,7 +181,7 @@ private:
TString PathPrefix_;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TGetOperationResponseParser
: public TResponseParserBase<TOperationAttributes>
@@ -194,7 +194,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TTableColumnarStatisticsParser
: public TResponseParserBase<TVector<TTableColumnarStatistics>>
@@ -209,7 +209,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TTablePartitionsParser
: public TResponseParserBase<TMultiTablePartitions>
@@ -241,7 +241,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TYPathParser
: public TResponseParserBase<TYPath>
@@ -254,7 +254,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TCheckPermissionParser
: public TResponseParserBase<TCheckPermissionResponse>
@@ -267,7 +267,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TRawBatchRequest::TBatchItem::TBatchItem(TNode parameters, ::TIntrusivePtr<IResponseItemParser> responseParser)
: Parameters(std::move(parameters))
@@ -281,7 +281,7 @@ TRawBatchRequest::TBatchItem::TBatchItem(const TBatchItem& batchItem, TInstant n
, NextTry(nextTry)
{ }
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TRawBatchRequest::TRawBatchRequest(const TConfigPtr& config)
: Config_(config)
diff --git a/yt/cpp/mapreduce/raw_client/raw_requests.cpp b/yt/cpp/mapreduce/raw_client/raw_requests.cpp
index 6426ccecf4c..2f9610a1ca3 100644
--- a/yt/cpp/mapreduce/raw_client/raw_requests.cpp
+++ b/yt/cpp/mapreduce/raw_client/raw_requests.cpp
@@ -28,7 +28,7 @@
namespace NYT::NDetail::NRawClient {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void ExecuteBatch(
IRequestRetryPolicyPtr retryPolicy,
diff --git a/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp b/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp
index 8392eaccdf3..a638ac581dc 100644
--- a/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp
+++ b/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp
@@ -18,7 +18,7 @@ namespace NYT::NDetail::NRawClient {
using ::ToString;
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static void SetTransactionIdParam(TNode* node, const TTransactionId& transactionId)
{
@@ -105,7 +105,7 @@ void SerializeMasterReadOptions(TNode* node, const TMasterReadOptions<T>& option
}
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TNode SerializeParamsForCreate(
const TTransactionId& transactionId,
diff --git a/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h b/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h
index dfe70bbcc55..a7ab35d91d6 100644
--- a/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h
+++ b/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h
@@ -5,7 +5,7 @@
namespace NYT::NDetail::NRawClient {
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TNode SerializeParamsForCreate(
const TTransactionId& transactionId,
@@ -224,6 +224,6 @@ TNode SerializeParamsForStartTransaction(
TDuration txTimeout,
const TStartTransactionOptions& options);
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NDetail::NRawClient