Skip to main content

translate_create_source

Function translate_create_source 

Source
pub fn translate_create_source(
    stmt: CreateSourceStatement,
) -> Result<SourceDefinition, ParseError>
Expand description

Translates a CREATE SOURCE statement to a typed SourceDefinition.

ยงErrors

Returns ParseError::ValidationError if:

  • The channel option is specified (not user-configurable)
  • An invalid option value is provided
  • Column types cannot be converted to Arrow types