pub fn translate_create_source_with_columns(
stmt: CreateSourceStatement,
columns: Vec<ColumnDefinition>,
) -> Result<SourceDefinition, ParseError>Expand description
Translate a CREATE SOURCE statement using an already-resolved column
list. Used by the DDL layer after discover_schema so WATERMARK FOR
validates against the discovered columns rather than the SQL text.
ยงErrors
Returns ParseError from option validation or watermark parsing.