Fix fmt

Author: fpetkovski

datafusion/catalog/src/stream.rs

@@ -55,7 +55,11 @@ impl TableProviderFactory for StreamTableFactory {
     ) -> Result<Arc<dyn TableProvider>> {
         let location = match cmd.locations.len() {
             1 => &cmd.locations[0],
-            _ => return config_err!("Stream table factory supports only a single table location"),
+            _ => {
+                return config_err!(
+                    "Stream table factory supports only a single table location"
+                )
+            }
         };
 
         let schema: SchemaRef = Arc::clone(cmd.schema.inner());

datafusion/core/src/datasource/listing_table_factory.rs

@@ -26,8 +26,6 @@ use std::collections::HashSet;
 use std::path::Path;
 use std::sync::Arc;
 
-use arrow::datatypes::DataType;
-use datafusion_common::{arrow_datafusion_err, plan_err, DataFusionError, ToDFSchema};
 use arrow::datatypes::{DataType, SchemaRef};
 use datafusion_common::{config_datafusion_err, Result};
 use datafusion_common::{plan_err, DFSchema, DataFusionError, ToDFSchema};

datafusion/core/src/test_util/mod.rs

@@ -184,8 +184,8 @@ impl TableProviderFactory for TestTableFactory {
         cmd: &CreateExternalTable,
     ) -> Result<Arc<dyn TableProvider>> {
         Ok(Arc::new(TestTableProvider {
-            url: cmd.locations,
-            schema: Arc::new(cmd.schema.as_ref().into()),
+            url: cmd.locations.clone(),
+            schema: Arc::clone(cmd.schema.inner()),
         }))
     }
 }

datafusion/proto/src/logical_plan/mod.rs

@@ -625,7 +625,7 @@ impl AsLogicalPlan for LogicalPlanNode {
                             create_extern_table.name.as_ref(),
                             "CreateExternalTable",
                         )?,
-                        locations: create_extern_table.location.clone(),
+                        locations: vec![create_extern_table.location.clone()],
                         file_type: create_extern_table.file_type.clone(),
                         table_partition_cols: create_extern_table
                             .table_partition_cols
@@ -1499,7 +1499,7 @@ impl AsLogicalPlan for LogicalPlanNode {
                     logical_plan_type: Some(LogicalPlanType::CreateExternalTable(
                         protobuf::CreateExternalTableNode {
                             name: Some(name.clone().into()),
-                            location: location.clone(),
+                            location: location.clone().join(","),
                             file_type: file_type.clone(),
                             schema: Some(df_schema.try_into()?),
                             table_partition_cols: table_partition_cols.clone(),

datafusion/proto/tests/cases/roundtrip_logical_plan.rs

@@ -196,7 +196,7 @@ impl LogicalExtensionCodec for TestTableProviderCodec {
         })?;
         assert_eq!(msg.table_name, table_ref.to_string());
         let provider = TestTableProvider {
-            url: msg.url,
+            url: vec![msg.url],
             schema,
         };
         Ok(Arc::new(provider))
@@ -214,7 +214,7 @@ impl LogicalExtensionCodec for TestTableProviderCodec {
             .downcast_ref::<TestTableProvider>()
             .expect("Can't encode non-test tables");
         let msg = TestTableProto {
-            url: table.url.clone(),
+            url: table.url.join(","),
             table_name: table_ref.to_string(),
         };
         msg.encode(buf).map_err(|_| {