You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: datafusion/sqllogictest/test_files/push_down_filter_regression.slt
-40Lines changed: 0 additions & 40 deletions
Original file line number
Diff line number
Diff line change
@@ -220,26 +220,6 @@ set datafusion.explain.physical_plan_only = true;
220
220
statement ok
221
221
create external table agg_reordered_pushdown stored as parquet location '../../parquet-testing/data/alltypes_plain.parquet';
222
222
223
-
# Filter on grouping column b should push below the aggregate even though the
224
-
# aggregate input is reordered to (c, a, b).
225
-
query TT
226
-
explain
227
-
select a, b, cnt
228
-
from (
229
-
select a, b, count(c) as cnt
230
-
from (
231
-
select id as c, cast(string_col as varchar) as a, bool_col as b
232
-
from agg_reordered_pushdown
233
-
) t
234
-
group by a, b
235
-
) q
236
-
where b = true;
237
-
----
238
-
physical_plan
239
-
01)ProjectionExec: expr=[a@0 as a, b@1 as b, count(t.c)@2 as cnt]
240
-
02)--AggregateExec: mode=Single, gby=[a@1 as a, b@2 as b], aggr=[count(t.c)]
241
-
03)----DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/parquet-testing/data/alltypes_plain.parquet]]}, projection=[id@0 as c, CAST(string_col@9 AS Utf8View) as a, bool_col@1 as b], file_type=parquet, predicate=bool_col@1, pruning_predicate=bool_col_min@0 OR bool_col_max@1, required_guarantees=[]
242
-
243
223
query TBI rowsort
244
224
select a, b, cnt
245
225
from (
@@ -254,26 +234,6 @@ where b = true;
254
234
----
255
235
0 true 4
256
236
257
-
# Filter on aggregate output must remain above the aggregate.
258
-
query TT
259
-
explain
260
-
select a, b, cnt
261
-
from (
262
-
select a, b, count(c) as cnt
263
-
from (
264
-
select id as c, cast(string_col as varchar) as a, bool_col as b
265
-
from agg_reordered_pushdown
266
-
) t
267
-
group by a, b
268
-
) q
269
-
where cnt > 1;
270
-
----
271
-
physical_plan
272
-
01)ProjectionExec: expr=[a@0 as a, b@1 as b, count(t.c)@2 as cnt]
273
-
02)--FilterExec: count(t.c)@2 > 1
274
-
03)----AggregateExec: mode=Single, gby=[a@1 as a, b@2 as b], aggr=[count(t.c)]
275
-
04)------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/parquet-testing/data/alltypes_plain.parquet]]}, projection=[id@0 as c, CAST(string_col@9 AS Utf8View) as a, bool_col@1 as b], file_type=parquet
0 commit comments