Function mz_sql::pure::purify_create_source

source ·

async fn purify_create_source(
    catalog: impl SessionCatalog,
    now: u64,
    stmt: CreateSourceStatement<Aug>,
    storage_configuration: &StorageConfiguration
) -> Result<(Vec<(GlobalId, CreateSubsourceStatement<Aug>)>, Statement<Aug>), PlanError>