risingwave_connector::source::base

Function create_split_reader

source
pub async fn create_split_reader<P: SourceProperties>(
    prop: P,
    splits: Vec<SplitImpl>,
    parser_config: ParserConfig,
    source_ctx: SourceContextRef,
    columns: Option<Vec<Column>>,
) -> ConnectorResult<P::SplitReader>