Skip to content

Commit cbeb95e

Browse files
committed
chore: fix fmt and clippy errors
1 parent 2d6e298 commit cbeb95e

File tree

2 files changed

+16
-6
lines changed

2 files changed

+16
-6
lines changed

datafusion/datasource/src/file_scan_config.rs

+15-4
Original file line numberDiff line numberDiff line change
@@ -422,7 +422,7 @@ impl From<FileScanConfig> for FileScanConfigBuilder {
422422
Self {
423423
object_store_url: config.object_store_url,
424424
file_schema: config.file_schema,
425-
file_source: config.file_source.clone(),
425+
file_source: Arc::<dyn FileSource>::clone(&config.file_source),
426426
file_groups: config.file_groups,
427427
statistics: config.file_source.statistics().ok(),
428428
output_ordering: config.output_ordering,
@@ -2157,10 +2157,21 @@ mod tests {
21572157
assert!(config.constraints.is_empty());
21582158

21592159
// Verify statistics are set to unknown
2160-
assert_eq!(config.file_source.statistics().unwrap().num_rows, Precision::Absent);
2161-
assert_eq!(config.file_source.statistics().unwrap().total_byte_size, Precision::Absent);
21622160
assert_eq!(
2163-
config.file_source.statistics().unwrap().column_statistics.len(),
2161+
config.file_source.statistics().unwrap().num_rows,
2162+
Precision::Absent
2163+
);
2164+
assert_eq!(
2165+
config.file_source.statistics().unwrap().total_byte_size,
2166+
Precision::Absent
2167+
);
2168+
assert_eq!(
2169+
config
2170+
.file_source
2171+
.statistics()
2172+
.unwrap()
2173+
.column_statistics
2174+
.len(),
21642175
file_schema.fields().len()
21652176
);
21662177
for stat in config.file_source.statistics().unwrap().column_statistics {

datafusion/proto/tests/cases/roundtrip_physical_plan.rs

+1-2
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@ use crate::cases::{
2929
use arrow::array::RecordBatch;
3030
use arrow::csv::WriterBuilder;
3131
use arrow::datatypes::{Fields, TimeUnit};
32-
use datafusion::datasource::file_format::file_compression_type::FileCompressionType;
3332
use datafusion::physical_expr::aggregate::AggregateExprBuilder;
3433
use datafusion::physical_plan::coalesce_batches::CoalesceBatchesExec;
3534
use datafusion_expr::dml::InsertOp;
@@ -97,7 +96,7 @@ use datafusion_common::file_options::json_writer::JsonWriterOptions;
9796
use datafusion_common::parsers::CompressionTypeVariant;
9897
use datafusion_common::stats::Precision;
9998
use datafusion_common::{
100-
internal_err, not_impl_err, Constraints, DataFusionError, Result, UnnestOptions,
99+
internal_err, not_impl_err, DataFusionError, Result, UnnestOptions,
101100
};
102101
use datafusion_expr::{
103102
Accumulator, AccumulatorFactoryFunction, AggregateUDF, ColumnarValue, ScalarUDF,

0 commit comments

Comments
 (0)