Struct datafusion::sql::planner::SqlToRel
source · pub struct SqlToRel<'a, S>where
S: ContextProvider,{ /* private fields */ }
Expand description
SQL query planner
Implementations§
source§impl<'a, S> SqlToRel<'a, S>where
S: ContextProvider,
impl<'a, S> SqlToRel<'a, S>where S: ContextProvider,
sourcepub fn sql_to_expr(
&self,
sql: Expr,
schema: &DFSchema,
planner_context: &mut PlannerContext
) -> Result<Expr, DataFusionError>
pub fn sql_to_expr( &self, sql: Expr, schema: &DFSchema, planner_context: &mut PlannerContext ) -> Result<Expr, DataFusionError>
Generate a relational expression from a SQL expression
source§impl<'a, S> SqlToRel<'a, S>where
S: ContextProvider,
impl<'a, S> SqlToRel<'a, S>where S: ContextProvider,
sourcepub fn new_with_options(
context_provider: &'a S,
options: ParserOptions
) -> SqlToRel<'a, S>
pub fn new_with_options( context_provider: &'a S, options: ParserOptions ) -> SqlToRel<'a, S>
Create a new query planner
pub fn build_schema( &self, columns: Vec<ColumnDef> ) -> Result<Schema, DataFusionError>
source§impl<'a, S> SqlToRel<'a, S>where
S: ContextProvider,
impl<'a, S> SqlToRel<'a, S>where S: ContextProvider,
sourcepub fn statement_to_plan(
&self,
statement: Statement
) -> Result<LogicalPlan, DataFusionError>
pub fn statement_to_plan( &self, statement: Statement ) -> Result<LogicalPlan, DataFusionError>
Generate a logical plan from an DataFusion SQL statement
sourcepub fn sql_statement_to_plan(
&self,
statement: Statement
) -> Result<LogicalPlan, DataFusionError>
pub fn sql_statement_to_plan( &self, statement: Statement ) -> Result<LogicalPlan, DataFusionError>
Generate a logical plan from an SQL statement
sourcepub fn sql_statement_to_plan_with_context(
&self,
statement: Statement,
planner_context: &mut PlannerContext
) -> Result<LogicalPlan, DataFusionError>
pub fn sql_statement_to_plan_with_context( &self, statement: Statement, planner_context: &mut PlannerContext ) -> Result<LogicalPlan, DataFusionError>
Generate a logical plan from an SQL statement
Auto Trait Implementations§
impl<'a, S> RefUnwindSafe for SqlToRel<'a, S>where S: RefUnwindSafe,
impl<'a, S> Send for SqlToRel<'a, S>where S: Sync,
impl<'a, S> Sync for SqlToRel<'a, S>where S: Sync,
impl<'a, S> Unpin for SqlToRel<'a, S>
impl<'a, S> UnwindSafe for SqlToRel<'a, S>where S: RefUnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more