Upgrade datafusion to 51, arrow to 57 (#151)

Author: nuno-faria

Cargo.toml

@@ -11,10 +11,10 @@ readme = "README.md"
 repository = "https://github.com/datafusion-contrib/datafusion-federation"
 
 [workspace.dependencies]
-arrow-json = "56"
+arrow-json = "57"
 async-stream = "0.3.5"
 async-trait = "0.1.83"
-datafusion = "50.0.0"
+datafusion = "51.0.0"
 datafusion-federation = { path = "./datafusion-federation", version = "0.4.10" }
 futures = "0.3.31"
 tokio = { version = "1.41", features = ["full"] }

datafusion-federation/src/sql/mod.rs

@@ -166,7 +166,7 @@ pub struct VirtualExecutionPlan {
 
 impl VirtualExecutionPlan {
     pub fn new(plan: LogicalPlan, executor: Arc<dyn SQLExecutor>, statistics: Statistics) -> Self {
-        let schema: Schema = plan.schema().as_ref().into();
+        let schema: Schema = plan.schema().as_arrow().clone();
         let props = PlanProperties::new(
             EquivalenceProperties::new(Arc::new(schema)),
             Partitioning::UnknownPartitioning(1),
@@ -194,8 +194,8 @@ impl VirtualExecutionPlan {
     }
 
     fn schema(&self) -> SchemaRef {
-        let df_schema = self.plan.schema().as_ref();
-        Arc::new(Schema::from(df_schema))
+        let df_schema = self.plan.schema().as_arrow().clone();
+        Arc::new(df_schema)
     }
 
     fn final_sql(&self) -> Result<String> {