Skip to main content

translate_create_sink

Function translate_create_sink 

Source
pub fn translate_create_sink(
    stmt: CreateSinkStatement,
) -> Result<SinkDefinition, ParseError>
Expand description

Translates a CREATE SINK statement to a typed SinkDefinition.

ยงErrors

Returns ParseError::ValidationError if:

  • The channel option is specified (not user-configurable)
  • An invalid option value is provided