risingwave_stream::from_proto::sink

Function validate_payload_schema

Source 
fn validate_payload_schema(
    log_store_payload_schema: &[PbColumnCatalog],
    input_schema: &Schema,
) -> StreamResult<()>