Rename crate from datafusion-distributed-experiment to datafusion-distributed

Author: gabotechs

Cargo.lock

@@ -1,5 +1,5 @@
 [package]
-name = "datafusion-distributed-experiment"
+name = "datafusion-distributed"
 version = "0.1.0"
 edition = "2021"
 

Cargo.toml

@@ -16,7 +16,7 @@ pub trait SessionBuilder {
     /// # use datafusion::execution::{FunctionRegistry, SessionStateBuilder};
     /// # use datafusion::physical_plan::ExecutionPlan;
     /// # use datafusion_proto::physical_plan::PhysicalExtensionCodec;
-    /// # use datafusion_distributed_experiment::{SessionBuilder};
+    /// # use datafusion_distributed::{SessionBuilder};
     ///
     /// #[derive(Debug)]
     /// struct CustomExecCodec;

src/flight_service/session_builder.rs

@@ -4,7 +4,7 @@ use datafusion::common::runtime::JoinSet;
 use datafusion::common::DataFusionError;
 use datafusion::execution::SessionStateBuilder;
 use datafusion::prelude::SessionContext;
-use datafusion_distributed_experiment::{
+use datafusion_distributed::{
     ArrowFlightChannel, ArrowFlightEndpoint, BoxCloneSyncChannel, ChannelManager, ChannelResolver,
     SessionBuilder,
 };

tests/common/localhost.rs

@@ -4,7 +4,7 @@ use datafusion::error::DataFusionError;
 use datafusion::physical_expr::Partitioning;
 use datafusion::physical_plan::aggregates::{AggregateExec, AggregateMode};
 use datafusion::physical_plan::ExecutionPlan;
-use datafusion_distributed_experiment::ArrowFlightReadExec;
+use datafusion_distributed::ArrowFlightReadExec;
 use std::sync::Arc;
 
 pub fn distribute_aggregate(

tests/common/plan.rs

@@ -26,7 +26,7 @@ mod tests {
     use datafusion::physical_plan::{
         displayable, execute_stream, DisplayAs, DisplayFormatType, ExecutionPlan, PlanProperties,
     };
-    use datafusion_distributed_experiment::{ArrowFlightReadExec, SessionBuilder};
+    use datafusion_distributed::{ArrowFlightReadExec, SessionBuilder};
     use datafusion_proto::physical_plan::PhysicalExtensionCodec;
     use datafusion_proto::protobuf::proto_error;
     use futures::{stream, TryStreamExt};

tests/custom_extension_codec.rs

@@ -7,7 +7,7 @@ mod tests {
     use crate::common::parquet::register_parquet_tables;
     use datafusion::physical_expr::Partitioning;
     use datafusion::physical_plan::{displayable, execute_stream};
-    use datafusion_distributed_experiment::ArrowFlightReadExec;
+    use datafusion_distributed::ArrowFlightReadExec;
     use futures::TryStreamExt;
     use std::error::Error;
     use std::sync::Arc;