risingwave_connector::source::base

Function extract_source_struct

Source 
pub fn extract_source_struct(
    info: &PbStreamSourceInfo,
) -> ConnectorResult<SourceStruct>