risingwave_connector::source::reader::desc::test_utils

Function create_source_desc_builder

source 
pub fn create_source_desc_builder(
    schema: &Schema,
    row_id_index: Option<usize>,
    source_info: StreamSourceInfo,
    with_properties: BTreeMap<String, String>,
    pk_indices: Vec<usize>,
) -> SourceDescBuilder