Skip to main content

decode_table_pk

risingwave_stream::from_proto::stream_cdc_scan

Function decode_table_pk 

Source 
fn decode_table_pk(
    table_desc: &ExternalTableDesc,
    table_type: &ExternalCdcTableType,
) -> StreamResult<(Vec<OrderType>, Option<Vec<CdcKeyComparison>>, Vec<usize>)>