Function sql::pure::purify_csr_connector_avro [−][src]
async fn purify_csr_connector_avro(
connector: &mut CreateSourceConnector,
csr_connector: &mut CsrConnectorAvro<Raw>,
envelope: &Envelope,
connector_options: &BTreeMap<String, String>
) -> Result<(), Error>