Function mz_sql::pure::purify_csr_connection_avro
source ยท async fn purify_csr_connection_avro(
catalog: &dyn SessionCatalog,
options: &SourceFormatOptions,
csr_connection: &mut CsrConnectionAvro<Aug>,
envelope: &Option<SourceEnvelope>,
storage_configuration: &StorageConfiguration,
) -> Result<(), PlanError>