aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorudovichenko-r <rvu@ydb.tech>2023-08-22 19:06:46 +0300
committerudovichenko-r <rvu@ydb.tech>2023-08-22 19:39:50 +0300
commite5b54c01ed686c0d9e00e31ac2ef1b5efcf89800 (patch)
treee46fa3bd1001315a971715751c0b0e6700305628
parenta42171b3cf1fa15a4276d31465f2b8621c9fbc86 (diff)
downloadydb-e5b54c01ed686c0d9e00e31ac2ef1b5efcf89800.tar.gz
[yql] fix style
-rw-r--r--ydb/library/yql/providers/dq/provider/yql_dq_validate.cpp16
1 files changed, 10 insertions, 6 deletions
diff --git a/ydb/library/yql/providers/dq/provider/yql_dq_validate.cpp b/ydb/library/yql/providers/dq/provider/yql_dq_validate.cpp
index eb1f5c14e1e..8109656191c 100644
--- a/ydb/library/yql/providers/dq/provider/yql_dq_validate.cpp
+++ b/ydb/library/yql/providers/dq/provider/yql_dq_validate.cpp
@@ -103,19 +103,23 @@ private:
if (TDqSource::Match(&node) || TDqTransform::Match(&node) || TDqSink::Match(&node)) {
return true;
}
-
+
ReportError(Ctx_, node, TStringBuilder() << "Failed to execute callable with name: " << node.Content() << " in DQ");
return false;
}
public:
- TDqExecutionValidator(const TTypeAnnotationContext& typeCtx, TExprContext& ctx, const TDqState::TPtr state) : TypeCtx_(typeCtx), Ctx_(ctx), State_(state) {}
-
+ TDqExecutionValidator(const TTypeAnnotationContext& typeCtx, TExprContext& ctx, const TDqState::TPtr state)
+ : TypeCtx_(typeCtx)
+ , Ctx_(ctx)
+ , State_(state)
+ {}
+
bool ValidateDqExecution(const TExprNode& node) {
YQL_LOG_CTX_SCOPE(__FUNCTION__);
TNodeSet dqNodes;
-
+
bool hasJoin = false;
if (TDqCnResult::Match(&node)) {
dqNodes.insert(TDqCnResult(&node).Output().Stage().Raw());
@@ -156,7 +160,7 @@ public:
for (auto& [integration, nodes]: ReadsPerProvider_) {
TMaybe<ui64> size;
- hasError |= !(size = integration->EstimateReadSize(State_->Settings->DataSizePerJob.Get().GetOrElse(TDqSettings::TDefault::DataSizePerJob),
+ hasError |= !(size = integration->EstimateReadSize(State_->Settings->DataSizePerJob.Get().GetOrElse(TDqSettings::TDefault::DataSizePerJob),
State_->Settings->MaxTasksPerStage.Get().GetOrElse(TDqSettings::TDefault::MaxTasksPerStage), nodes, Ctx_));
if (hasError) {
break;
@@ -178,7 +182,7 @@ private:
THashMap<IDqIntegration*, TVector<const TExprNode*>> ReadsPerProvider_;
size_t DataSize_ = 0;
const TDqState::TPtr State_;
-
+
};
}