async fn purify_create_source(
catalog: impl SessionCatalog,
now: u64,
create_source_stmt: CreateSourceStatement<Aug>,
storage_configuration: &StorageConfiguration,
) -> Result<PurifiedStatement, PlanError>
async fn purify_create_source(
catalog: impl SessionCatalog,
now: u64,
create_source_stmt: CreateSourceStatement<Aug>,
storage_configuration: &StorageConfiguration,
) -> Result<PurifiedStatement, PlanError>