Skip to content

Commit b2c7f1f

Browse files
committed
Update core crate to rust edition 2024
1 parent 2bea796 commit b2c7f1f

File tree

129 files changed

+1358
-1172
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

129 files changed

+1358
-1172
lines changed

datafusion/core/Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ keywords = ["arrow", "query", "sql"]
2222
include = ["benches/*.rs", "src/**/*.rs", "Cargo.toml", "LICENSE.txt", "NOTICE.txt"]
2323
readme = "../../README.md"
2424
version = { workspace = true }
25-
edition = { workspace = true }
25+
edition = "2024"
2626
homepage = { workspace = true }
2727
repository = { workspace = true }
2828
license = { workspace = true }

datafusion/core/benches/data_utils/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,9 +18,9 @@
1818
//! This module provides the in-memory table for more realistic benchmarking.
1919
2020
use arrow::array::{
21-
builder::{Int64Builder, StringBuilder},
2221
ArrayRef, Float32Array, Float64Array, RecordBatch, StringArray, StringViewBuilder,
2322
UInt64Array,
23+
builder::{Int64Builder, StringBuilder},
2424
};
2525
use arrow::datatypes::{DataType, Field, Schema, SchemaRef};
2626
use datafusion::datasource::MemTable;

datafusion/core/benches/distinct_query_sql.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,10 +24,10 @@ mod data_utils;
2424
use crate::criterion::Criterion;
2525
use data_utils::{create_table_provider, make_data};
2626
use datafusion::execution::context::SessionContext;
27-
use datafusion::physical_plan::{collect, ExecutionPlan};
27+
use datafusion::physical_plan::{ExecutionPlan, collect};
2828
use datafusion::{datasource::MemTable, error::Result};
29-
use datafusion_execution::config::SessionConfig;
3029
use datafusion_execution::TaskContext;
30+
use datafusion_execution::config::SessionConfig;
3131

3232
use parking_lot::Mutex;
3333
use std::hint::black_box;

datafusion/core/benches/filter_query_sql.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ use arrow::{
2020
datatypes::{DataType, Field, Schema},
2121
record_batch::RecordBatch,
2222
};
23-
use criterion::{criterion_group, criterion_main, Criterion};
23+
use criterion::{Criterion, criterion_group, criterion_main};
2424
use datafusion::prelude::SessionContext;
2525
use datafusion::{datasource::MemTable, error::Result};
2626
use futures::executor::block_on;

datafusion/core/benches/map_query_sql.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,10 +20,10 @@ use std::hint::black_box;
2020
use std::sync::Arc;
2121

2222
use arrow::array::{ArrayRef, Int32Array, RecordBatch};
23-
use criterion::{criterion_group, criterion_main, Criterion};
23+
use criterion::{Criterion, criterion_group, criterion_main};
2424
use parking_lot::Mutex;
25-
use rand::prelude::ThreadRng;
2625
use rand::Rng;
26+
use rand::prelude::ThreadRng;
2727
use tokio::runtime::Runtime;
2828

2929
use datafusion::prelude::SessionContext;

datafusion/core/benches/parquet_query_sql.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,14 +23,14 @@ use arrow::datatypes::{
2323
SchemaRef,
2424
};
2525
use arrow::record_batch::RecordBatch;
26-
use criterion::{criterion_group, criterion_main, Criterion};
26+
use criterion::{Criterion, criterion_group, criterion_main};
2727
use datafusion::prelude::{SessionConfig, SessionContext};
2828
use datafusion_common::instant::Instant;
2929
use futures::stream::StreamExt;
3030
use parquet::arrow::ArrowWriter;
3131
use parquet::file::properties::{WriterProperties, WriterVersion};
32-
use rand::distr::uniform::SampleUniform;
3332
use rand::distr::Alphanumeric;
33+
use rand::distr::uniform::SampleUniform;
3434
use rand::prelude::*;
3535
use rand::rng;
3636
use std::fs::File;

datafusion/core/benches/physical_plan.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ use tokio::runtime::Runtime;
3232
use datafusion::physical_plan::sorts::sort_preserving_merge::SortPreservingMergeExec;
3333
use datafusion::physical_plan::{
3434
collect,
35-
expressions::{col, PhysicalSortExpr},
35+
expressions::{PhysicalSortExpr, col},
3636
};
3737
use datafusion::prelude::SessionContext;
3838
use datafusion_datasource::memory::MemorySourceConfig;

datafusion/core/benches/preserve_file_partitioning.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,8 +38,8 @@ use arrow::array::{ArrayRef, Float64Array, StringArray, TimestampMillisecondArra
3838
use arrow::datatypes::{DataType, Field, Schema, TimeUnit};
3939
use arrow::record_batch::RecordBatch;
4040
use arrow::util::pretty::pretty_format_batches;
41-
use criterion::{criterion_group, criterion_main, Criterion};
42-
use datafusion::prelude::{col, ParquetReadOptions, SessionConfig, SessionContext};
41+
use criterion::{Criterion, criterion_group, criterion_main};
42+
use datafusion::prelude::{ParquetReadOptions, SessionConfig, SessionContext, col};
4343
use datafusion_expr::SortExpr;
4444
use parquet::arrow::ArrowWriter;
4545
use parquet::file::properties::WriterProperties;

datafusion/core/benches/push_down_filter.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,16 +18,16 @@
1818
use arrow::array::RecordBatch;
1919
use arrow::datatypes::{DataType, Field, Schema};
2020
use bytes::{BufMut, BytesMut};
21-
use criterion::{criterion_group, criterion_main, Criterion};
21+
use criterion::{Criterion, criterion_group, criterion_main};
2222
use datafusion::config::ConfigOptions;
2323
use datafusion::prelude::{ParquetReadOptions, SessionContext};
2424
use datafusion_execution::object_store::ObjectStoreUrl;
25-
use datafusion_physical_optimizer::filter_pushdown::FilterPushdown;
2625
use datafusion_physical_optimizer::PhysicalOptimizerRule;
26+
use datafusion_physical_optimizer::filter_pushdown::FilterPushdown;
2727
use datafusion_physical_plan::ExecutionPlan;
28+
use object_store::ObjectStore;
2829
use object_store::memory::InMemory;
2930
use object_store::path::Path;
30-
use object_store::ObjectStore;
3131
use parquet::arrow::ArrowWriter;
3232
use std::sync::Arc;
3333

datafusion/core/benches/scalar.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
// specific language governing permissions and limitations
1616
// under the License.
1717

18-
use criterion::{criterion_group, criterion_main, Criterion};
18+
use criterion::{Criterion, criterion_group, criterion_main};
1919
use datafusion::scalar::ScalarValue;
2020

2121
fn criterion_benchmark(c: &mut Criterion) {

0 commit comments

Comments
 (0)