Skip to content

Commit 7e28cc4

Browse files
committed
update snapshot
1 parent be006e8 commit 7e28cc4

File tree

1 file changed

+1
-1
lines changed
  • datafusion/core/tests/physical_optimizer/filter_pushdown

1 file changed

+1
-1
lines changed

datafusion/core/tests/physical_optimizer/filter_pushdown/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1326,7 +1326,7 @@ async fn test_hashjoin_dynamic_filter_pushdown_partitioned() {
13261326
- DataSourceExec: file_groups={1 group: [[test.parquet]]}, projection=[a, b, c], file_type=test, pushdown_supported=true
13271327
- CoalesceBatchesExec: target_batch_size=8192
13281328
- RepartitionExec: partitioning=Hash([a@0, b@1], 12), input_partitions=1
1329-
- DataSourceExec: file_groups={1 group: [[test.parquet]]}, projection=[a, b, e], file_type=test, pushdown_supported=true, predicate=DynamicFilter [ a@0 >= aa AND a@0 <= ab AND b@1 >= ba AND b@1 <= bb ]
1329+
- DataSourceExec: file_groups={1 group: [[test.parquet]]}, projection=[a, b, e], file_type=test, pushdown_supported=true, predicate=DynamicFilter [ CASE hash_repartition % 12 WHEN 0 THEN a@0 >= aa AND a@0 <= ab AND b@1 >= ba AND b@1 <= bb AND lookup_p0 WHEN 1 THEN lookup_p1 WHEN 2 THEN lookup_p2 WHEN 3 THEN lookup_p3 WHEN 4 THEN lookup_p4 WHEN 5 THEN lookup_p5 WHEN 6 THEN lookup_p6 WHEN 7 THEN lookup_p7 WHEN 8 THEN lookup_p8 WHEN 9 THEN lookup_p9 WHEN 10 THEN lookup_p10 WHEN 11 THEN lookup_p11 ELSE false END ]
13301330
"
13311331
);
13321332

0 commit comments

Comments
 (0)