pub async fn create_split_readers<P: SourceProperties>(
prop: P,
splits: Vec<SplitImpl>,
parser_config: ParserConfig,
source_ctx: SourceContextRef,
columns: Option<Vec<Column>>,
opt: CreateSplitReaderOpt,
) -> ConnectorResult<(BoxSourceChunkStream, CreateSplitReaderResult)>