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 <[email protected]>
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 <[email protected]>
---
.../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: [email protected]
For additional commands, e-mail: [email protected]
