risingwave_stream::from_proto::source::trad_source

Function create_source_desc_builder

source 
pub fn create_source_desc_builder(
    source_type: &str,
    source_id: &TableId,
    source_columns: Vec<PbColumnCatalog>,
    params: &ExecutorParams,
    source_info: PbStreamSourceInfo,
    row_id_index: Option<u32>,
    with_properties: WithOptionsSecResolved,
) -> SourceDescBuilder