aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/interface
diff options
context:
space:
mode:
authorpavook <pavook@yandex-team.com>2024-08-22 16:26:27 +0300
committerpavook <pavook@yandex-team.com>2024-08-22 16:39:20 +0300
commit8520e043f2e12acdfd39d971ebeeacbe9e5ac3ca (patch)
tree55e2c5a3efebd951a92445ed5c7327c86479f655 /yt/cpp/mapreduce/interface
parentf9fbb65f64b68c5de5cf257c04e06ac6aeaeb1e8 (diff)
downloadydb-8520e043f2e12acdfd39d971ebeeacbe9e5ac3ca.tar.gz
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/mapreduce/interface')
-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
9 files changed, 33 insertions, 33 deletions
diff --git a/yt/cpp/mapreduce/interface/batch_request.h b/yt/cpp/mapreduce/interface/batch_request.h
index 3ea28f76fd..8056f8a1ed 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 49a7c7cfc1..ef3d2db4a3 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 1d7f5375a2..becde0def2 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 717982e216..2d0284e2b1 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 573cbe4784..24efddd7d0 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 4ff8dde3cc..0ee952f510 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 4582d9e872..a41b48d5c6 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 76b67138a3..9e17ca7e90 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 81d03d0618..b28a33142a 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();
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
generated by cgit v1.2.3 (git 2.25.1) at 2025-03-29 09:40:25 +0000