Skip to main content

plan_sql_distributed

mongreldb_query::distributed

Function plan_sql_distributed 

Source 
pub async fn plan_sql_distributed(
    sql: &str,
    catalog: &PlanningTableCatalog,
    locator: &dyn TabletLocator,
    metadata: &dyn ClusterMetadata,
) -> DistributedResult<DistributedPlan>
Expand description

Public gateway entry: parse sql with DataFusion against catalog, then lower via DataFusionDistributedPlanner onto locator/metadata.

This is the product seam for cluster SQL planning (P0.4). Callers supply planning schemas (column names/types) for every table the SQL references; placement uses TabletLocator / ClusterMetadata, not a standalone local catalog scan.