aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraidarsamer <aidarsamer@ydb.tech>2022-12-19 11:37:43 +0300
committeraidarsamer <aidarsamer@ydb.tech>2022-12-19 11:37:43 +0300
commitcd7b43afadb45daa054bd3882511703e7200ca57 (patch)
tree1176e3ca8208399023ed4574efe55ed3b06e37b3
parent802fbca45bbde7ff4929c9fe85e136d794a42e49 (diff)
downloadydb-cd7b43afadb45daa054bd3882511703e7200ca57.tar.gz
Add DisableEmitAggApply pragma
Add DisableEmitAggApply pragma
-rw-r--r--ydb/library/yql/sql/v1/sql.cpp6
1 files changed, 6 insertions, 0 deletions
diff --git a/ydb/library/yql/sql/v1/sql.cpp b/ydb/library/yql/sql/v1/sql.cpp
index 5e71ff50b8f..2569d59b7d1 100644
--- a/ydb/library/yql/sql/v1/sql.cpp
+++ b/ydb/library/yql/sql/v1/sql.cpp
@@ -10058,9 +10058,15 @@ TNodePtr TSqlQuery::PragmaStatement(const TRule_pragma_stmt& stmt, bool& success
} else if (normalizedPragma == "emitaggapply") {
Ctx.EmitAggApply = true;
Ctx.IncrementMonCounter("sql_pragma", "EmitAggApply");
+ } else if (normalizedPragma == "disableemitaggapply") {
+ Ctx.EmitAggApply = false;
+ Ctx.IncrementMonCounter("sql_pragma", "DisableEmitAggApply");
} else if (normalizedPragma == "useblocks") {
Ctx.UseBlocks = true;
Ctx.IncrementMonCounter("sql_pragma", "UseBlocks");
+ } else if (normalizedPragma == "disableuseblocks") {
+ Ctx.UseBlocks = false;
+ Ctx.IncrementMonCounter("sql_pragma", "DisableUseBlocks");
} else {
Error() << "Unknown pragma: " << pragma;
Ctx.IncrementMonCounter("sql_errors", "UnknownPragma");