flow::recording_rules::utils

Function sql_to_df_plan

Source
pub async fn sql_to_df_plan(
    query_ctx: QueryContextRef,
    engine: QueryEngineRef,
    sql: &str,
    optimize: bool,
) -> Result<LogicalPlan, Error>
Expand description

Convert sql to datafusion logical plan