You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ro...@apache.org on 2023/11/13 18:33:54 UTC
(pinot) branch master updated: [test][multistage] adding filter pushdown tests (#11994)
This is an automated email from the ASF dual-hosted git repository.
rongr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 610c36afb6 [test][multistage] adding filter pushdown tests (#11994)
610c36afb6 is described below
commit 610c36afb6d64c533e613be5fa4eeb0a861503ae
Author: Rong Rong <ro...@apache.org>
AuthorDate: Mon Nov 13 10:33:48 2023 -0800
[test][multistage] adding filter pushdown tests (#11994)
following up on #11989.
adding more tests for filter pushdown rules on the runtime side.
Co-authored-by: Rong Rong <ro...@startree.ai>
---
.../src/test/resources/queries/FromExpressions.json | 20 ++++++++++++++++++++
1 file changed, 20 insertions(+)
diff --git a/pinot-query-runtime/src/test/resources/queries/FromExpressions.json b/pinot-query-runtime/src/test/resources/queries/FromExpressions.json
index 40a0962d68..7e91824304 100644
--- a/pinot-query-runtime/src/test/resources/queries/FromExpressions.json
+++ b/pinot-query-runtime/src/test/resources/queries/FromExpressions.json
@@ -381,6 +381,26 @@
{
"description": "join with mixed equality and inequality conditions",
"sql": "SELECT * FROM {tbl1} JOIN {tbl2} ON {tbl1}.strCol1 = {tbl2}.strCol1 AND {tbl1}.intCol1 > {tbl2}.doubleCol1"
+ },
+ {
+ "description": "join with push-down filter pass lower aggregate",
+ "sql": "SELECT * FROM (SELECT {tbl1}.strCol1, SUM({tbl1}.intCol1) FROM {tbl1} JOIN {tbl2} ON {tbl1}.strCol1 = {tbl2}.strCol1 WHERE {tbl2}.intCol1 > {tbl2}.doubleCol1 GROUP BY 1) WHERE strCol1 NOT IN ('bar', 'alice')"
+ },
+ {
+ "description": "semi-join with push-down filter pass lower aggregate",
+ "sql": "SELECT * FROM (SELECT {tbl1}.strCol1, SUM({tbl1}.intCol1) FROM {tbl1} WHERE {tbl1}.strCol1 IN (SELECT {tbl2}.strCol1 FROM {tbl2} WHERE {tbl2}.intCol1 > {tbl2}.doubleCol1) GROUP BY 1) WHERE strCol1 NOT IN ('bar', 'alice')"
+ },
+ {
+ "description": "join with push-down filter pass lower aggregate with having filter",
+ "sql": "SELECT * FROM (SELECT {tbl1}.strCol1, SUM({tbl1}.intCol1) FROM {tbl1} JOIN {tbl2} ON {tbl1}.strCol1 = {tbl2}.strCol1 WHERE {tbl2}.intCol1 > {tbl2}.doubleCol1 GROUP BY 1 HAVING COUNT(*) > 1) WHERE strCol1 NOT IN ('bar', 'alice')"
+ },
+ {
+ "description": "semi-join with push-down filter pass lower aggregate with having filter",
+ "sql": "SELECT * FROM (SELECT {tbl1}.strCol1, SUM({tbl1}.intCol1) FROM {tbl1} WHERE {tbl1}.strCol1 IN (SELECT {tbl2}.strCol1 FROM {tbl2} WHERE {tbl2}.intCol1 > {tbl2}.doubleCol1) GROUP BY 1 HAVING COUNT(*) > 1) WHERE strCol1 NOT IN ('bar', 'alice')"
+ },
+ {
+ "description": "nested query with push-down filter pass inner aggregate",
+ "sql": "SELECT * FROM (SELECT {tbl1}.strCol1, SUM({tbl1}.intCol1) FROM {tbl1} GROUP BY {tbl1}.strCol1 HAVING COUNT(*) > 1) WHERE strCol1 NOT IN ('bar', 'alice')"
}
]
},
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org