move plans/ to execution_plans/

Author: gabotechs

src/plan/arrow_flight_read.rs renamed to src/execution_plans/arrow_flight_read.rs

@@ -1,8 +1,8 @@
 use crate::channel_manager_ext::get_distributed_channel_resolver;
 use crate::config_extension_ext::ContextGrpcMetadata;
 use crate::errors::{map_flight_to_datafusion_error, map_status_to_datafusion_error};
+use crate::execution_plans::DistributedCodec;
 use crate::flight_service::{DoGet, StageKey};
-use crate::plan::DistributedCodec;
 use crate::stage::{proto_from_stage, ExecutionStage};
 use crate::ChannelResolver;
 use arrow_flight::decode::FlightRecordBatchStream;

src/plan/codec.rs renamed to src/execution_plans/codec.rs

@@ -1,6 +1,6 @@
 use super::PartitionIsolatorExec;
 use crate::common::ComposedPhysicalExtensionCodec;
-use crate::plan::arrow_flight_read::ArrowFlightReadExec;
+use crate::execution_plans::arrow_flight_read::ArrowFlightReadExec;
 use crate::user_codec_ext::get_distributed_user_codec;
 use datafusion::arrow::datatypes::Schema;
 use datafusion::execution::FunctionRegistry;

src/plan/mod.rs renamed to src/execution_plans/mod.rs

@@ -1,7 +1,7 @@
 mod arrow_flight_read;
 mod codec;
-mod isolator;
+mod partition_isolator;
 
 pub use arrow_flight_read::ArrowFlightReadExec;
 pub use codec::DistributedCodec;
-pub use isolator::{PartitionGroup, PartitionIsolatorExec};
+pub use partition_isolator::{PartitionGroup, PartitionIsolatorExec};

src/plan/isolator.rs renamed to src/execution_plans/partition_isolator.rs

@@ -1,9 +1,9 @@
 use super::service::StageKey;
 use crate::config_extension_ext::ContextGrpcMetadata;
 use crate::errors::datafusion_error_to_tonic_status;
+use crate::execution_plans::{DistributedCodec, PartitionGroup};
 use crate::flight_service::service::ArrowFlightEndpoint;
 use crate::flight_service::session_builder::DistributedSessionBuilderContext;
-use crate::plan::{DistributedCodec, PartitionGroup};
 use crate::stage::{stage_from_proto, ExecutionStage, ExecutionStageProto};
 use arrow_flight::encode::FlightDataEncoderBuilder;
 use arrow_flight::error::FlightError;

src/flight_service/do_get.rs

@@ -5,9 +5,9 @@ mod common;
 mod config_extension_ext;
 mod distributed_ext;
 mod errors;
+mod execution_plans;
 mod flight_service;
 mod physical_optimizer;
-mod plan;
 mod stage;
 mod task;
 mod user_codec_ext;
@@ -17,11 +17,11 @@ pub mod test_utils;
 
 pub use channel_manager_ext::{BoxCloneSyncChannel, ChannelResolver};
 pub use distributed_ext::DistributedExt;
+pub use execution_plans::{ArrowFlightReadExec, PartitionIsolatorExec};
 pub use flight_service::{
     ArrowFlightEndpoint, DefaultSessionBuilder, DistributedSessionBuilder,
     DistributedSessionBuilderContext, MappedDistributedSessionBuilder,
     MappedDistributedSessionBuilderExt,
 };
 pub use physical_optimizer::DistributedPhysicalOptimizerRule;
-pub use plan::ArrowFlightReadExec;
 pub use stage::{display_stage_graphviz, ExecutionStage};

src/lib.rs

@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
 use super::stage::ExecutionStage;
-use crate::{plan::PartitionIsolatorExec, ArrowFlightReadExec};
+use super::{ArrowFlightReadExec, PartitionIsolatorExec};
 use datafusion::common::tree_node::TreeNodeRecursion;
 use datafusion::error::DataFusionError;
 use datafusion::physical_plan::joins::PartitionMode;

src/physical_optimizer.rs

@@ -1,5 +1,5 @@
 use super::ExecutionStage;
-use crate::plan::PartitionIsolatorExec;
+use crate::PartitionIsolatorExec;
 use crate::{
     task::{format_pg, ExecutionTask},
     ArrowFlightReadExec,