aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorDenis Khalikov <deniskhalikov@ydb.tech>2025-04-21 15:23:34 +0300
committerGitHub <noreply@github.com>2025-04-21 15:23:34 +0300
commitef35ffef726ed786e6145e3172dae71aeaddceac (patch)
tree22169f2c249c2cbe60931cf2433add61193ce5d5
parentd2f33847cfb36147544f73a1e72aaf0c22fe262d (diff)
downloadydb-ef35ffef726ed786e6145e3172dae71aeaddceac.tar.gz
Add optimization flags (#16098) (#17476)
-rw-r--r--ydb/core/kqp/host/kqp_host.cpp3
-rw-r--r--ydb/core/kqp/ut/join/kqp_join_ut.cpp2
2 files changed, 5 insertions, 0 deletions
diff --git a/ydb/core/kqp/host/kqp_host.cpp b/ydb/core/kqp/host/kqp_host.cpp
index e88e610ccdf..f3dcf8337f4 100644
--- a/ydb/core/kqp/host/kqp_host.cpp
+++ b/ydb/core/kqp/host/kqp_host.cpp
@@ -1976,6 +1976,9 @@ private:
|| settingName == "TimeOrderRecoverAhead"
|| settingName == "TimeOrderRecoverRowLimit"
|| settingName == "MatchRecognizeStream"
+ || settingName == "OptimizerFlags"
+ || settingName == "FuseEquiJoinsInputMultiLabels"
+ || settingName == "PullUpFlatMapOverJoinMultipleLabels"
;
};
auto configProvider = CreateConfigProvider(*TypesCtx, gatewaysConfig, {}, allowSettings);
diff --git a/ydb/core/kqp/ut/join/kqp_join_ut.cpp b/ydb/core/kqp/ut/join/kqp_join_ut.cpp
index c1f2963ec03..e671be26e88 100644
--- a/ydb/core/kqp/ut/join/kqp_join_ut.cpp
+++ b/ydb/core/kqp/ut/join/kqp_join_ut.cpp
@@ -616,6 +616,7 @@ Y_UNIT_TEST_SUITE(KqpJoin) {
{
auto result = session.ExecuteDataQuery(Q_(R"(
PRAGMA FilterPushdownOverJoinOptionalSide;
+ PRAGMA config.flags("OptimizerFlags", "FuseEquiJoinsInputMultiLabels", "PullUpFlatMapOverJoinMultipleLabels");
SELECT t1.Key1, t1.Key2, t1.Fk1, t1.Value, t2.Key, t2.Value, t3.Key, t3.Value
@@ -639,6 +640,7 @@ Y_UNIT_TEST_SUITE(KqpJoin) {
{
auto result = session.ExecuteDataQuery(Q_(R"(
PRAGMA FilterPushdownOverJoinOptionalSide;
+ PRAGMA config.flags("OptimizerFlags", "FuseEquiJoinsInputMultiLabels", "PullUpFlatMapOverJoinMultipleLabels");
SELECT t1.Key1, t1.Key2, t1.Fk1, t1.Value, t2.Key, t2.Value, t3.Key, t3.Value