risingwave_frontend::handler::create_sink

Function bind_sink_format_desc

source 
fn bind_sink_format_desc(
    session: &SessionImpl,
    value: FormatEncodeOptions,
) -> Result<SinkFormatDesc, RwError>
Expand description

Transforms the (format, encode, options) from sqlparser AST into an internal struct SinkFormatDesc. This is an analogy to (part of) crate::handler::create_source::bind_columns_from_source which transforms sqlparser AST SourceSchemaV2 into StreamSourceInfo.