diff options
| author | Igor Makunin <igor.makunin@gmail.com> | 2022-03-14 21:00:25 +0300 |
|---|---|---|
| committer | Igor Makunin <igor.makunin@gmail.com> | 2022-03-14 21:00:25 +0300 |
| commit | d1bc881834ebd37e9e66175b92a75a070a95e76e (patch) | |
| tree | 2d818ac624ec28d3265a3506756710f13dfbf7e4 | |
| parent | 155684596947619545253a469124225cf66cf4bc (diff) | |
| download | ydb-d1bc881834ebd37e9e66175b92a75a070a95e76e.tar.gz | |
KIKIMR-14496: drop redundant precompute stage over parameter
ref:4b0871effc2565e5aebdcf5f209ac0b01111d6ad
| -rw-r--r-- | ydb/core/kqp/ut/kqp_indexes_ut.cpp | 4 | ||||
| -rw-r--r-- | ydb/library/yql/dq/opt/dq_opt_phy.cpp | 2 |
2 files changed, 4 insertions, 2 deletions
diff --git a/ydb/core/kqp/ut/kqp_indexes_ut.cpp b/ydb/core/kqp/ut/kqp_indexes_ut.cpp index 51b35dd84d..a7bff4ce4a 100644 --- a/ydb/core/kqp/ut/kqp_indexes_ut.cpp +++ b/ydb/core/kqp/ut/kqp_indexes_ut.cpp @@ -4777,8 +4777,8 @@ R"([[#;#;["Primary1"];[41u]];[["Secondary2"];[2u];["Primary2"];[42u]];[["Seconda int readPhase = 0; if (UseNewEngine) { - UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 4); - readPhase = 2; + UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 3); + readPhase = 1; } UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(readPhase).table_access().size(), 1); diff --git a/ydb/library/yql/dq/opt/dq_opt_phy.cpp b/ydb/library/yql/dq/opt/dq_opt_phy.cpp index 015a36c300..e29a22bffe 100644 --- a/ydb/library/yql/dq/opt/dq_opt_phy.cpp +++ b/ydb/library/yql/dq/opt/dq_opt_phy.cpp @@ -1438,6 +1438,8 @@ TExprBase DqBuildPrecompute(TExprBase node, TExprContext& ctx) { connection = input.Ptr(); } else if (input.Maybe<TDqCnValue>()) { connection = input.Ptr(); + } else if (input.Maybe<TCoParameter>()) { + return input; } else if (IsDqPureExpr(input)) { if (input.Ref().GetTypeAnn()->GetKind() != ETypeAnnotationKind::List && input.Ref().GetTypeAnn()->GetKind() != ETypeAnnotationKind::Data) |