pub fn create_stream( format: &Format, config: &ScanPlanConfig<'_>, ) -> Result<SendableRecordBatchStream>