Skip to main content

prepare_csr_connection_avro

mz_sql::pure

Function prepare_csr_connection_avro 

Source 
fn prepare_csr_connection_avro(
    catalog: &dyn SessionCatalog,
    options: &SourceFormatOptions,
    csr_connection: &CsrConnectionAvro<Aug>,
    envelope: &Option<SourceEnvelope>,
) -> Result<Option<CsrAvroPreparation>, PlanError>