risingwave_frontend::handler::create_source

Function check_format_encode

source 
pub(super) async fn check_format_encode(
    props: &WithOptionsSecResolved,
    row_id_index: Option<usize>,
    columns: &[ColumnCatalog],
) -> Result<(), RwError>
Expand description

Performs early stage checking in frontend to see if the schema of the given columns is compatible with the connector extracted from the properties.

One should only call this function after all properties of all columns are resolved, like generated column descriptors.