Skip to content

Commit 04a8b9e

Browse files
committed
fix
1 parent 97b5810 commit 04a8b9e

File tree

3 files changed

+5
-6
lines changed

3 files changed

+5
-6
lines changed

datafusion/core/tests/physical_optimizer/mod.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ mod combine_partial_final_agg;
2424
mod enforce_distribution;
2525
mod enforce_sorting;
2626
mod enforce_sorting_monotonicity;
27-
#[expect(clippy::needless_pass_by_value)]
2827
mod filter_pushdown;
2928
mod join_selection;
3029
#[expect(clippy::needless_pass_by_value)]

datafusion/core/tests/physical_optimizer/pushdown_utils.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,7 @@ pub struct TestSource {
113113
impl TestSource {
114114
pub fn new(schema: SchemaRef, support: bool, batches: Vec<RecordBatch>) -> Self {
115115
let table_schema =
116-
datafusion_datasource::TableSchema::new(Arc::clone(&schema), vec![]);
116+
datafusion_datasource::TableSchema::new(schema, vec![]);
117117
Self {
118118
support,
119119
metrics: ExecutionPlanMetricsSet::new(),
@@ -359,6 +359,7 @@ pub struct OptimizationTest {
359359
}
360360

361361
impl OptimizationTest {
362+
#[expect(clippy::needless_pass_by_value)]
362363
pub fn new<O>(
363364
input_plan: Arc<dyn ExecutionPlan>,
364365
opt: O,

datafusion/core/tests/sql/explain_analyze.rs

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -996,10 +996,9 @@ async fn parquet_recursive_projection_pushdown() -> Result<()> {
996996
SortExec: expr=[id@0 ASC NULLS LAST], preserve_partitioning=[false]
997997
RecursiveQueryExec: name=number_series, is_distinct=false
998998
CoalescePartitionsExec
999-
ProjectionExec: expr=[id@0 as id, 1 as level]
1000-
FilterExec: id@0 = 1
1001-
RepartitionExec: partitioning=RoundRobinBatch(NUM_CORES), input_partitions=1
1002-
DataSourceExec: file_groups={1 group: [[TMP_DIR/hierarchy.parquet]]}, projection=[id], file_type=parquet, predicate=id@0 = 1, pruning_predicate=id_null_count@2 != row_count@3 AND id_min@0 <= 1 AND 1 <= id_max@1, required_guarantees=[id in (1)]
999+
FilterExec: id@0 = level@1
1000+
RepartitionExec: partitioning=RoundRobinBatch(NUM_CORES), input_partitions=1
1001+
DataSourceExec: file_groups={1 group: [[TMP_DIR/hierarchy.parquet]]}, projection=[id, 1 as level], file_type=parquet, predicate=id@0 = 1, pruning_predicate=id_null_count@2 != row_count@3 AND id_min@0 <= 1 AND 1 <= id_max@1, required_guarantees=[id in (1)]
10031002
CoalescePartitionsExec
10041003
ProjectionExec: expr=[id@0 + 1 as ns.id + Int64(1), level@1 + 1 as ns.level + Int64(1)]
10051004
FilterExec: id@0 < 10

0 commit comments

Comments
 (0)