Skip to content

Commit ef35ffe

Browse files
authored
Add optimization flags (#16098) (#17476)
1 parent d2f3384 commit ef35ffe

File tree

2 files changed

+5
-0
lines changed

2 files changed

+5
-0
lines changed

ydb/core/kqp/host/kqp_host.cpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1976,6 +1976,9 @@ class TKqpHost : public IKqpHost {
19761976
|| settingName == "TimeOrderRecoverAhead"
19771977
|| settingName == "TimeOrderRecoverRowLimit"
19781978
|| settingName == "MatchRecognizeStream"
1979+
|| settingName == "OptimizerFlags"
1980+
|| settingName == "FuseEquiJoinsInputMultiLabels"
1981+
|| settingName == "PullUpFlatMapOverJoinMultipleLabels"
19791982
;
19801983
};
19811984
auto configProvider = CreateConfigProvider(*TypesCtx, gatewaysConfig, {}, allowSettings);

ydb/core/kqp/ut/join/kqp_join_ut.cpp

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -616,6 +616,7 @@ Y_UNIT_TEST_SUITE(KqpJoin) {
616616
{
617617
auto result = session.ExecuteDataQuery(Q_(R"(
618618
PRAGMA FilterPushdownOverJoinOptionalSide;
619+
PRAGMA config.flags("OptimizerFlags", "FuseEquiJoinsInputMultiLabels", "PullUpFlatMapOverJoinMultipleLabels");
619620
620621
SELECT t1.Key1, t1.Key2, t1.Fk1, t1.Value, t2.Key, t2.Value, t3.Key, t3.Value
621622
@@ -639,6 +640,7 @@ Y_UNIT_TEST_SUITE(KqpJoin) {
639640
{
640641
auto result = session.ExecuteDataQuery(Q_(R"(
641642
PRAGMA FilterPushdownOverJoinOptionalSide;
643+
PRAGMA config.flags("OptimizerFlags", "FuseEquiJoinsInputMultiLabels", "PullUpFlatMapOverJoinMultipleLabels");
642644
643645
SELECT t1.Key1, t1.Key2, t1.Fk1, t1.Value, t2.Key, t2.Value, t3.Key, t3.Value
644646

0 commit comments

Comments
 (0)