risingwave_frontend::handler::create_sink

Function derive_default_column_project_for_sink

Source 
pub(crate) fn derive_default_column_project_for_sink(
    sink: &SinkCatalog,
    sink_schema: &Schema,
    columns: &[ColumnCatalog],
    user_specified_columns: bool,
) -> Result<Vec<ExprImpl>, RwError>