Function purify_create_sink_avro_doc_on_options

Source

pub(crate) fn purify_create_sink_avro_doc_on_options(
    catalog: &dyn SessionCatalog,
    from_id: CatalogItemId,
    format: &mut Option<FormatSpecifier<Aug>>,
) -> Result<(), PlanError>

Expand description

Injects DOC ON comments into all Avro formats that are using a schema registry by finding all SQL COMMENTs that are attached to the sink’s underlying materialized view (as well as any types referenced by that underlying materialized view).

Function purify_create_sink_avro_doc_on_optionsCopy item path

Function purify_create_sink_avro_doc_on_options