This is an automated email from the ASF dual-hosted git repository.
alamb pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new 5a2933e587 fix typo in test file name (#16403)
5a2933e587 is described below
commit 5a2933e5878777c75c931b42327b1074bcd43d35
Author: Adrian Garcia Badaracco <1755071+adria...@users.noreply.github.com>
AuthorDate: Fri Jun 13 15:17:20 2025 -0500
fix typo in test file name (#16403)
---
.../physical_optimizer/filter_pushdown/mod.rs | 44 +++++++++++-----------
.../physical_optimizer/filter_pushdown/util.rs | 2 +-
2 files changed, 23 insertions(+), 23 deletions(-)
diff --git a/datafusion/core/tests/physical_optimizer/filter_pushdown/mod.rs
b/datafusion/core/tests/physical_optimizer/filter_pushdown/mod.rs
index a28933d97b..16dba7e3f2 100644
--- a/datafusion/core/tests/physical_optimizer/filter_pushdown/mod.rs
+++ b/datafusion/core/tests/physical_optimizer/filter_pushdown/mod.rs
@@ -55,10 +55,10 @@ fn test_pushdown_into_scan() {
OptimizationTest:
input:
- FilterExec: a@0 = foo
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
output:
Ok:
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo
"
);
}
@@ -81,11 +81,11 @@ fn test_pushdown_into_scan_with_config_options() {
OptimizationTest:
input:
- FilterExec: a@0 = foo
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
output:
Ok:
- FilterExec: a@0 = foo
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
"
);
@@ -100,10 +100,10 @@ fn test_pushdown_into_scan_with_config_options() {
OptimizationTest:
input:
- FilterExec: a@0 = foo
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
output:
Ok:
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo
"
);
}
@@ -124,10 +124,10 @@ fn test_filter_collapse() {
input:
- FilterExec: b@1 = bar
- FilterExec: a@0 = foo
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
output:
Ok:
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo AND b@1 = bar
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo AND b@1 = bar
"
);
}
@@ -151,11 +151,11 @@ fn test_filter_with_projection() {
OptimizationTest:
input:
- FilterExec: a@0 = foo, projection=[b@1, a@0]
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
output:
Ok:
- ProjectionExec: expr=[b@1 as b, a@0 as a]
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo
",
);
@@ -174,11 +174,11 @@ fn test_filter_with_projection() {
OptimizationTest:
input:
- FilterExec: a@0 = foo, projection=[b@1]
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
output:
Ok:
- ProjectionExec: expr=[b@1 as b]
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo
"
);
}
@@ -206,12 +206,12 @@ fn test_push_down_through_transparent_nodes() {
- RepartitionExec: partitioning=RoundRobinBatch(1),
input_partitions=1
- FilterExec: a@0 = foo
- CoalesceBatchesExec: target_batch_size=1
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
output:
Ok:
- RepartitionExec: partitioning=RoundRobinBatch(1),
input_partitions=1
- CoalesceBatchesExec: target_batch_size=1
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo AND b@1 = bar
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo AND b@1 = bar
"
);
}
@@ -271,14 +271,14 @@ fn test_no_pushdown_through_aggregates() {
- AggregateExec: mode=Final, gby=[a@0 as a, b@1 as b], aggr=[cnt],
ordering_mode=PartiallySorted([0])
- FilterExec: a@0 = foo
- CoalesceBatchesExec: target_batch_size=10
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
output:
Ok:
- FilterExec: b@1 = bar
- CoalesceBatchesExec: target_batch_size=100
- AggregateExec: mode=Final, gby=[a@0 as a, b@1 as b], aggr=[cnt]
- CoalesceBatchesExec: target_batch_size=10
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo
"
);
}
@@ -298,11 +298,11 @@ fn test_node_handles_child_pushdown_result() {
OptimizationTest:
input:
- TestInsertExec { inject_filter: true }
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true
output:
Ok:
- TestInsertExec { inject_filter: true }
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=a@0 =
foo
",
);
@@ -317,12 +317,12 @@ fn test_node_handles_child_pushdown_result() {
OptimizationTest:
input:
- TestInsertExec { inject_filter: true }
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=false
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=false
output:
Ok:
- TestInsertExec { inject_filter: false }
- FilterExec: a@0 = foo
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=false
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=false
",
);
@@ -337,11 +337,11 @@ fn test_node_handles_child_pushdown_result() {
OptimizationTest:
input:
- TestInsertExec { inject_filter: false }
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=false
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=false
output:
Ok:
- TestInsertExec { inject_filter: false }
- - DataSourceExec: file_groups={1 group: [[test.paqruet]]},
projection=[a, b, c], file_type=test, pushdown_supported=false
+ - DataSourceExec: file_groups={1 group: [[test.parquet]]},
projection=[a, b, c], file_type=test, pushdown_supported=false
",
);
}
diff --git a/datafusion/core/tests/physical_optimizer/filter_pushdown/util.rs
b/datafusion/core/tests/physical_optimizer/filter_pushdown/util.rs
index 958dd8f59e..c60d2b4d81 100644
--- a/datafusion/core/tests/physical_optimizer/filter_pushdown/util.rs
+++ b/datafusion/core/tests/physical_optimizer/filter_pushdown/util.rs
@@ -278,7 +278,7 @@ impl TestScanBuilder {
Arc::clone(&self.schema),
source,
)
- .with_file(PartitionedFile::new("test.paqruet", 123))
+ .with_file(PartitionedFile::new("test.parquet", 123))
.build();
DataSourceExec::from_data_source(base_config)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@datafusion.apache.org
For additional commands, e-mail: commits-h...@datafusion.apache.org
