Skip to content

Commit e718c76

Browse files
committed
revert accidental change
1 parent 24afb59 commit e718c76

1 file changed

Lines changed: 35 additions & 0 deletions

File tree

datafusion/sqllogictest/test_files/parquet_filter_pushdown.slt

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -246,3 +246,38 @@ physical_plan
246246
02)--FilterExec: val@0 != part@1
247247
03)----RepartitionExec: partitioning=RoundRobinBatch(4), input_partitions=1
248248
04)------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/parquet_filter_pushdown/parquet_part_test/part=a/file.parquet]]}, projection=[val, part], file_type=parquet, predicate=val@0 != d AND val@0 != c, pruning_predicate=val_null_count@2 != row_count@3 AND (val_min@0 != d OR d != val_max@1) AND val_null_count@2 != row_count@3 AND (val_min@0 != c OR c != val_max@1), required_guarantees=[val not in (c, d)]
249+
250+
# The order of filters should not matter
251+
query TT
252+
EXPLAIN select val, part from t_pushdown where part = 'a' AND part = val;
253+
----
254+
logical_plan
255+
01)Filter: t_pushdown.val = t_pushdown.part
256+
02)--TableScan: t_pushdown projection=[val, part], full_filters=[t_pushdown.part = Utf8("a")], partial_filters=[t_pushdown.val = t_pushdown.part]
257+
physical_plan
258+
01)CoalesceBatchesExec: target_batch_size=8192
259+
02)--FilterExec: val@0 = part@1
260+
03)----RepartitionExec: partitioning=RoundRobinBatch(4), input_partitions=1
261+
04)------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/parquet_filter_pushdown/parquet_part_test/part=a/file.parquet]]}, projection=[val, part], file_type=parquet
262+
263+
query TT
264+
select val, part from t_pushdown where part = 'a' AND part = val;
265+
----
266+
a a
267+
268+
query TT
269+
EXPLAIN select val, part from t_pushdown where part = val AND part = 'a';
270+
----
271+
logical_plan
272+
01)Filter: t_pushdown.val = t_pushdown.part
273+
02)--TableScan: t_pushdown projection=[val, part], full_filters=[t_pushdown.part = Utf8("a")], partial_filters=[t_pushdown.val = t_pushdown.part]
274+
physical_plan
275+
01)CoalesceBatchesExec: target_batch_size=8192
276+
02)--FilterExec: val@0 = part@1
277+
03)----RepartitionExec: partitioning=RoundRobinBatch(4), input_partitions=1
278+
04)------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/parquet_filter_pushdown/parquet_part_test/part=a/file.parquet]]}, projection=[val, part], file_type=parquet
279+
280+
query TT
281+
select val, part from t_pushdown where part = val AND part = 'a';
282+
----
283+
a a

0 commit comments

Comments
 (0)