risingwave_frontend::handler::create_source

Function bind_columns_from_source

source 
pub(crate) async fn bind_columns_from_source(
    session: &SessionImpl,
    format_encode: &FormatEncodeOptions,
    with_properties: Either<&WithOptions, &WithOptionsSecResolved>,
) -> Result<(Option<Vec<ColumnCatalog>>, StreamSourceInfo), RwError>
Expand description

Resolves the schema of the source from external schema file. See https://www.risingwave.dev/docs/current/sql-create-source for more information.

Note: the returned schema strictly corresponds to the schema. Other special columns like additional columns (INCLUDE), and row_id column are not included.