diff options
author | udovichenko-r <rvu@ydb.tech> | 2023-08-22 19:06:46 +0300 |
---|---|---|
committer | udovichenko-r <rvu@ydb.tech> | 2023-08-22 19:39:50 +0300 |
commit | e5b54c01ed686c0d9e00e31ac2ef1b5efcf89800 (patch) | |
tree | e46fa3bd1001315a971715751c0b0e6700305628 | |
parent | a42171b3cf1fa15a4276d31465f2b8621c9fbc86 (diff) | |
download | ydb-e5b54c01ed686c0d9e00e31ac2ef1b5efcf89800.tar.gz |
[yql] fix style
-rw-r--r-- | ydb/library/yql/providers/dq/provider/yql_dq_validate.cpp | 16 |
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_; - + }; } |