extract_source_struct

risingwave_connector::source::base

Function extract_source_struct 

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