diff --git a/crates/ingestd/src/schema_evolution.rs b/crates/ingestd/src/schema_evolution.rs index fa7db93..1f7f8e9 100644 --- a/crates/ingestd/src/schema_evolution.rs +++ b/crates/ingestd/src/schema_evolution.rs @@ -2,12 +2,9 @@ /// When a source changes format (columns renamed, added, removed, type changed), /// the system detects the diff and can auto-map using AI or heuristic matching. -#[allow(unused_imports)] -use arrow::datatypes::{DataType, Schema, SchemaRef}; +use arrow::datatypes::{DataType, SchemaRef}; use serde::{Deserialize, Serialize}; use std::collections::HashMap; -#[allow(unused_imports)] -use std::sync::Arc; /// A detected change between two schema versions. #[derive(Debug, Clone, Serialize, Deserialize)] @@ -225,7 +222,8 @@ fn find_similar_column<'a>( #[cfg(test)] mod tests { use super::*; - use arrow::datatypes::Field; + use arrow::datatypes::{Field, Schema}; + use std::sync::Arc; fn schema(fields: Vec<(&str, DataType)>) -> SchemaRef { Arc::new(Schema::new(