Function mz_sql::kafka_util::extract_config

source · [−]
pub fn extract_config(
    with_options: &mut BTreeMap<String, SqlValueOrSecret>
) -> Result<BTreeMap<String, StringOrSecret>, PlanError>
Expand description

Parse the with_options from a CREATE SOURCE or CREATE SINK statement to determine user-supplied config options, e.g. security options.

Errors

  • Invalid values for known options, such as files that do not exist for expected file paths.
  • If any of the values in with_options are not sql_parser::ast::Value::String.