risingwave_
connector
2.4.0-alpha
In risingwave_
connector::
source::
base
risingwave_connector
::
source
::
base
Function
extract_source_struct
Copy item path
Source
pub fn extract_source_struct( info: &PbStreamSourceInfo, ) ->
ConnectorResult
<
SourceStruct
>