refactor(cubesql): Split QueryPlanner and QueryPlan (#8584)

Author: ovr

rust/cubesql/cubesql/benches/large_model.rs

@@ -3,12 +3,12 @@ use std::{env::set_var, sync::Arc, time::Duration};
 use criterion::{criterion_group, criterion_main, Criterion};
 
 use cubeclient::models::{V1CubeMeta, V1CubeMetaDimension, V1CubeMetaMeasure};
-use cubesql::compile::{
-    test::{
+use cubesql::{
+    compile::test::{
         rewrite_engine::{cube_context, query_to_logical_plan, rewrite_rules, rewrite_runner},
         sql_generator,
     },
-    MetaContext,
+    transport::MetaContext,
 };
 use egg::StopReason;
 use itertools::Itertools;

rust/cubesql/cubesql/src/compile/engine/context.rs

@@ -12,9 +12,9 @@ use datafusion::{
 };
 
 use crate::{
-    compile::{DatabaseProtocolDetails, MetaContext},
+    compile::DatabaseProtocolDetails,
     sql::{ColumnType, SessionManager, SessionState},
-    transport::{CubeMeta, V1CubeMetaExt},
+    transport::{CubeMeta, MetaContext, V1CubeMetaExt},
     CubeError,
 };
 

rust/cubesql/cubesql/src/compile/engine/df/scan.rs

@@ -31,8 +31,8 @@ use log::warn;
 use crate::{
     compile::{
         engine::df::wrapper::{CubeScanWrapperNode, SqlQuery},
-        find_cube_scans_deep_search,
         rewrite::WrappedSelectType,
+        test::find_cube_scans_deep_search,
     },
     config::ConfigObj,
     sql::AuthContextRef,
@@ -1326,11 +1326,9 @@ pub fn transform_response<V: ValueObject>(
 mod tests {
     use super::*;
     use crate::{
-        compile::{
-            engine::df::wrapper::SqlQuery, DatabaseProtocol, DatabaseProtocolDetails, MetaContext,
-        },
+        compile::{engine::df::wrapper::SqlQuery, DatabaseProtocol, DatabaseProtocolDetails},
         sql::HttpAuthContext,
-        transport::SqlResponse,
+        transport::{MetaContext, SqlResponse},
         CubeError,
     };
     use cubeclient::models::V1LoadResponse;

rust/cubesql/cubesql/src/compile/engine/information_schema/postgres/pg_class.rs

@@ -3,6 +3,7 @@ use std::{any::Any, sync::Arc};
 use async_trait::async_trait;
 use bigdecimal::ToPrimitive;
 
+use crate::transport::CubeMetaTable;
 use datafusion::{
     arrow::{
         array::{Array, ArrayRef, BooleanBuilder, Int32Builder, StringBuilder, UInt32Builder},
@@ -15,8 +16,6 @@ use datafusion::{
     physical_plan::{memory::MemoryExec, ExecutionPlan},
 };
 
-use crate::compile::CubeMetaTable;
-
 struct PgClass {
     oid: u32,
     relname: String,

rust/cubesql/cubesql/src/compile/engine/information_schema/postgres/pg_stat_user_tables.rs

@@ -2,6 +2,7 @@ use std::{any::Any, sync::Arc};
 
 use async_trait::async_trait;
 
+use crate::transport::CubeMetaTable;
 use datafusion::{
     arrow::{
         array::{
@@ -16,8 +17,6 @@ use datafusion::{
     physical_plan::{memory::MemoryExec, ExecutionPlan},
 };
 
-use crate::compile::CubeMetaTable;
-
 struct PgCatalogStatUserTablesBuilder {
     relid: UInt32Builder,
     schemaname: StringBuilder,

rust/cubesql/cubesql/src/compile/engine/information_schema/postgres/pg_statio_user_tables.rs

@@ -2,6 +2,7 @@ use std::{any::Any, sync::Arc};
 
 use async_trait::async_trait;
 
+use crate::transport::CubeMetaTable;
 use datafusion::{
     arrow::{
         array::{Array, ArrayRef, Int64Builder, StringBuilder, UInt32Builder},
@@ -14,8 +15,6 @@ use datafusion::{
     physical_plan::{memory::MemoryExec, ExecutionPlan},
 };
 
-use crate::compile::CubeMetaTable;
-
 struct PgCatalogStatioUserTablesBuilder {
     relid: UInt32Builder,
     schemaname: StringBuilder,

rust/cubesql/cubesql/src/compile/engine/information_schema/redshift/svv_table_info.rs

@@ -1,5 +1,6 @@
 use std::{any::Any, sync::Arc};
 
+use crate::transport::CubeMetaTable;
 use async_trait::async_trait;
 use datafusion::{
     arrow::{
@@ -16,8 +17,6 @@ use datafusion::{
     physical_plan::{memory::MemoryExec, ExecutionPlan},
 };
 
-use crate::compile::CubeMetaTable;
-
 struct RedshiftSvvTableInfoBuilder {
     databases: StringBuilder,
     schemas: StringBuilder,