diff --git a/datafusion-federation/src/plan_node.rs b/datafusion-federation/src/plan_node.rs index 0647f9d..0f1e299 100644 --- a/datafusion-federation/src/plan_node.rs +++ b/datafusion-federation/src/plan_node.rs @@ -16,8 +16,8 @@ use datafusion::{ }; pub struct FederatedPlanNode { - plan: LogicalPlan, - planner: Arc, + pub plan: LogicalPlan, + pub planner: Arc, } impl FederatedPlanNode { diff --git a/datafusion-federation/src/sql/mod.rs b/datafusion-federation/src/sql/mod.rs index b783cbf..59a62b4 100644 --- a/datafusion-federation/src/sql/mod.rs +++ b/datafusion-federation/src/sql/mod.rs @@ -28,7 +28,7 @@ use datafusion::{ pub use executor::{AstAnalyzer, LogicalOptimizer, SQLExecutor, SQLExecutorRef}; pub use schema::{MultiSchemaProvider, SQLSchemaProvider}; -pub use table::{RemoteTable, SQLTableSource}; +pub use table::{RemoteTable, SQLTable, SQLTableSource}; pub use table_reference::RemoteTableRef; use crate::{ @@ -38,8 +38,8 @@ use crate::{ // SQLFederationProvider provides federation to SQL DMBSs. #[derive(Debug)] pub struct SQLFederationProvider { - optimizer: Arc, - executor: Arc, + pub optimizer: Arc, + pub executor: Arc, } impl SQLFederationProvider { @@ -123,8 +123,8 @@ impl OptimizerRule for SQLFederationOptimizerRule { } #[derive(Debug)] -struct SQLFederationPlanner { - executor: Arc, +pub struct SQLFederationPlanner { + pub executor: Arc, } impl SQLFederationPlanner {