risingwave_frontend::handler::create_sink

Function derive_sink_to_table_expr

source 
fn derive_sink_to_table_expr(
    sink_schema: &Schema,
    idx: usize,
    target_type: &DataType,
) -> Result<ExprImpl, RwError>