Merge pull request #7767 from Xuanwo/remove-old-plan-parser

refactor: Old Planner Never See Again (Part 2)

Author: mergify[bot]

Cargo.lock

@@ -25,7 +25,6 @@ use common_tracing::set_panic_hook;
 use databend_query::api::HttpService;
 use databend_query::api::RpcService;
 use databend_query::clusters::ClusterDiscovery;
-use databend_query::interpreters::AsyncInsertManager;
 use databend_query::metrics::MetricService;
 use databend_query::servers::HttpHandler;
 use databend_query::servers::HttpHandlerKind;
@@ -165,13 +164,6 @@ async fn main(_global_tracker: Arc<RuntimeTracker>) -> common_exception::Result<
         );
     }
 
-    // Async Insert Queue
-    {
-        let async_insert_queue = AsyncInsertManager::instance();
-        async_insert_queue.start().await;
-        info!("Databend async insert has been enabled.")
-    }
-
     // Print information to users.
     println!("Databend Query");
     println!();

src/binaries/query/main.rs

@@ -26,7 +26,6 @@ use common_exception::Result;
 use common_functions::scalars::FunctionContext;
 use common_io::prelude::FormatSettings;
 use common_legacy_planners::Partitions;
-use common_legacy_planners::PlanNode;
 use common_legacy_planners::ReadDataSourcePlan;
 use common_meta_types::UserInfo;
 use common_settings::Settings;
@@ -87,7 +86,6 @@ pub trait TableContext: Send + Sync {
     fn apply_changed_settings(&self, changed_settings: Arc<Settings>) -> Result<()>;
     fn get_format_settings(&self) -> Result<FormatSettings>;
     fn get_tenant(&self) -> String;
-    fn get_subquery_name(&self, _query: &PlanNode) -> String;
     /// Get the data accessor metrics.
     fn get_dal_metrics(&self) -> DalMetrics;
     /// Get the session running query.

src/query/catalog/src/table_context.rs

@@ -12,12 +12,8 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-mod plan_aggregator_final;
-mod plan_aggregator_partial;
-mod plan_broadcast;
 mod plan_delete;
 mod plan_empty;
-mod plan_explain;
 mod plan_expression;
 mod plan_expression_action;
 mod plan_expression_chain;
@@ -26,46 +22,23 @@ mod plan_expression_common;
 mod plan_expression_function;
 mod plan_expression_literal;
 mod plan_expression_monotonicity;
-mod plan_expression_rewriter;
 mod plan_expression_sort;
 mod plan_expression_validator;
 mod plan_expression_visitor;
-mod plan_filter;
-mod plan_having;
-mod plan_insert_into;
-mod plan_limit;
-mod plan_limit_by;
-mod plan_node;
-mod plan_node_builder;
-mod plan_node_display;
-mod plan_node_display_indent;
 mod plan_node_extras;
-mod plan_node_rewriter;
 mod plan_node_stage;
 mod plan_node_stage_table;
 mod plan_node_statistics;
-mod plan_node_visitor;
 mod plan_partition;
-mod plan_projection;
 mod plan_read_datasource;
 mod plan_remote;
-mod plan_select;
 mod plan_setting;
 mod plan_sink;
-mod plan_sort;
-mod plan_subqueries_set;
 mod plan_table_recluster;
-mod plan_window_func;
 
-pub use plan_aggregator_final::AggregatorFinalPlan;
-pub use plan_aggregator_partial::AggregatorPartialPlan;
-pub use plan_broadcast::BroadcastPlan;
 pub use plan_delete::DeletePlan;
 pub use plan_empty::EmptyPlan;
-pub use plan_explain::ExplainPlan;
-pub use plan_explain::ExplainType;
 pub use plan_expression::Expression;
-pub use plan_expression::ExpressionPlan;
 pub use plan_expression::Expressions;
 pub use plan_expression_action::*;
 pub use plan_expression_chain::ExpressionChain;
@@ -96,47 +69,27 @@ pub use plan_expression_function::sum;
 pub use plan_expression_literal::lit;
 pub use plan_expression_literal::lit_null;
 pub use plan_expression_monotonicity::ExpressionMonotonicityVisitor;
-pub use plan_expression_rewriter::ExpressionRewriter;
 pub use plan_expression_sort::sort;
 pub use plan_expression_validator::validate_clustering;
 pub use plan_expression_validator::validate_expression;
 pub use plan_expression_validator::validate_function_arg;
 pub use plan_expression_visitor::ExpressionVisitor;
 pub use plan_expression_visitor::Recursion;
-pub use plan_filter::FilterPlan;
-pub use plan_having::HavingPlan;
-pub use plan_insert_into::InsertInputSource;
-pub use plan_insert_into::InsertPlan;
-pub use plan_insert_into::InsertValueBlock;
-pub use plan_limit::LimitPlan;
-pub use plan_limit_by::LimitByPlan;
-pub use plan_node::PlanNode;
-pub use plan_node_builder::PlanBuilder;
 pub use plan_node_extras::Extras;
 pub use plan_node_extras::PrewhereInfo;
 pub use plan_node_extras::Projection;
-pub use plan_node_rewriter::PlanRewriter;
-pub use plan_node_rewriter::RewriteHelper;
 pub use plan_node_stage::StageKind;
-pub use plan_node_stage::StagePlan;
 pub use plan_node_stage_table::StageTableInfo;
 pub use plan_node_statistics::Statistics;
-pub use plan_node_visitor::PlanVisitor;
 pub use plan_partition::PartInfo;
 pub use plan_partition::PartInfoPtr;
 pub use plan_partition::Partitions;
-pub use plan_projection::ProjectionPlan;
 pub use plan_read_datasource::ReadDataSourcePlan;
 pub use plan_read_datasource::SourceInfo;
 pub use plan_remote::RemotePlan;
 pub use plan_remote::V1RemotePlan;
 pub use plan_remote::V2RemotePlan;
-pub use plan_select::SelectPlan;
 pub use plan_setting::SettingPlan;
 pub use plan_setting::VarValue;
-pub use plan_sink::SinkPlan;
 pub use plan_sink::SINK_SCHEMA;
-pub use plan_sort::SortPlan;
-pub use plan_subqueries_set::SubQueriesSetPlan;
 pub use plan_table_recluster::ReclusterTablePlan;
-pub use plan_window_func::WindowFuncPlan;