给我一个用Scala编写的复杂一点的和药相关的spark实例,包含代码和数据

时间: 2024-05-14 16:18:49 浏览: 10
以下是一个使用Scala编写的复杂一点的和药相关的Spark实例,该实例使用了医药数据集,并对其进行了一些数据处理和分析。该实例的数据集可以在Kaggle上找到。 代码: ``` import org.apache.spark.sql.functions._ import org.apache.spark.sql.types._ import org.apache.spark.sql.{DataFrame, SparkSession} object DrugAnalysis { def main(args: Array[String]): Unit = { // Create a SparkSession val spark = SparkSession.builder .appName("Drug Analysis") .getOrCreate() // Read in the drug dataset val drugDF = spark.read.format("csv") .option("header", "true") .option("inferSchema", "true") .load("drug_data.csv") // Filter out any rows where the drug name is null val filteredDF = drugDF.filter(col("drugName").isNotNull) // Calculate the number of reviews for each drug val numReviewsDF = filteredDF.groupBy("drugName") .agg(count("drugName").alias("numReviews")) .orderBy(desc("numReviews")) // Calculate the average rating for each drug val avgRatingDF = filteredDF.groupBy("drugName") .agg(avg("rating").alias("avgRating")) .orderBy(desc("avgRating")) // Join the number of reviews and average rating data val joinedDF = numReviewsDF.join(avgRatingDF, Seq("drugName")) // Calculate the top 10 drugs by number of reviews val top10ReviewsDF = numReviewsDF.limit(10) // Calculate the top 10 drugs by average rating val top10RatingDF = avgRatingDF.limit(10) // Print out the top 10 drugs by number of reviews println("Top 10 Drugs by Number of Reviews:") top10ReviewsDF.show(false) // Print out the top 10 drugs by average rating println("Top 10 Drugs by Average Rating:") top10RatingDF.show(false) // Stop the SparkSession spark.stop() } } ``` 数据: drug_data.csv ``` patientId,drugName,condition,review,rating,date 206461,Valsartan,Left Ventricular Dysfunction,"""It has no side effect, I take it in combination of Bystolic 5 Mg and Fish Oil""",9,20-May-12 95260,Guanfacine,ADHD,"My son is halfway through his fourth week of Intuniv. We became concerned when he began this last week when he started taking the highest dose he will be on. We began to see him become agitated, aggressive and irritable on a daily basis. He had been on a lower dose last year and we had seen enormous improvements in his behavior. We spoke to the doctor and he told us to hang in there, that there is a ""break in period"" when dosage is increased. We are hoping that is what we are seeing now. So far he has not had any improvement in his ADHD symptoms but he is only taking 3mg in the morning and then another 3mg in the afternoon. It is becoming very difficult for us and for him in school and at home.",8,27-Apr-10 92703,Lybrel,Birth Control,"I used to take another oral contraceptive, which had 21 pills per cycle. This one has no break between cycles. I have not experienced any unwanted side effects. I am very happy with this product.",5,14-Dec-09 138000,Nexplanon,Birth Control,"I had been on the pill for many years. When my doctor told me about the implant, I agreed to it because I liked the idea of not having to remember to take a pill. I had it implanted in my arm in November of 2016. Since then, I have had two periods that were very heavy and lasted about 10 days each. I have also had spotting in between periods. I have gained weight and have been very moody. I have also had a lot of acne, which is something I never had before. I'm planning on having it removed soon.",8,08-Dec-16 ```

相关推荐

最新推荐

recommend-type

k8s1.16的jenkins部署java项目cicd(cd手动)-kubernetes安装包和详细文档笔记整理

k8s1.16的jenkins部署java项目cicd(cd手动)-kubernetes安装包和详细文档笔记整理
recommend-type

sja1311.x86_64.tar.gz

SQLyong 各个版本,免费下载 SQLyog是业界著名的Webyog公司出品的一款简洁高效、功能强大的图形化MySQL数据库管理工具。使用SQLyog可以快速直观地让您从世界的任何角落通过网络来维护远端的MySQL数据库。
recommend-type

debugpy-1.1.0-cp34-cp34m-manylinux1_x86_64.whl

Python库是一组预先编写的代码模块,旨在帮助开发者实现特定的编程任务,无需从零开始编写代码。这些库可以包括各种功能,如数学运算、文件操作、数据分析和网络编程等。Python社区提供了大量的第三方库,如NumPy、Pandas和Requests,极大地丰富了Python的应用领域,从数据科学到Web开发。Python库的丰富性是Python成为最受欢迎的编程语言之一的关键原因之一。这些库不仅为初学者提供了快速入门的途径,而且为经验丰富的开发者提供了强大的工具,以高效率、高质量地完成复杂任务。例如,Matplotlib和Seaborn库在数据可视化领域内非常受欢迎,它们提供了广泛的工具和技术,可以创建高度定制化的图表和图形,帮助数据科学家和分析师在数据探索和结果展示中更有效地传达信息。
recommend-type

SQLyog-12.5.0-0.x64Community.exe

SQLyog-12.5.0-0.x64Community
recommend-type

debugpy-1.0.0b12-cp35-cp35m-manylinux1_i686.whl

Python库是一组预先编写的代码模块,旨在帮助开发者实现特定的编程任务,无需从零开始编写代码。这些库可以包括各种功能,如数学运算、文件操作、数据分析和网络编程等。Python社区提供了大量的第三方库,如NumPy、Pandas和Requests,极大地丰富了Python的应用领域,从数据科学到Web开发。Python库的丰富性是Python成为最受欢迎的编程语言之一的关键原因之一。这些库不仅为初学者提供了快速入门的途径,而且为经验丰富的开发者提供了强大的工具,以高效率、高质量地完成复杂任务。例如,Matplotlib和Seaborn库在数据可视化领域内非常受欢迎,它们提供了广泛的工具和技术,可以创建高度定制化的图表和图形,帮助数据科学家和分析师在数据探索和结果展示中更有效地传达信息。
recommend-type

zigbee-cluster-library-specification

最新的zigbee-cluster-library-specification说明文档。
recommend-type

管理建模和仿真的文件

管理Boualem Benatallah引用此版本:布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学,1996年。法语。NNT:电话:00345357HAL ID:电话:00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆,用于存放和传播科学研究论文,无论它们是否被公开。论文可以来自法国或国外的教学和研究机构,也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
recommend-type

MATLAB柱状图在信号处理中的应用:可视化信号特征和频谱分析

![matlab画柱状图](https://img-blog.csdnimg.cn/3f32348f1c9c4481a6f5931993732f97.png) # 1. MATLAB柱状图概述** MATLAB柱状图是一种图形化工具,用于可视化数据中不同类别或组的分布情况。它通过绘制垂直条形来表示每个类别或组中的数据值。柱状图在信号处理中广泛用于可视化信号特征和进行频谱分析。 柱状图的优点在于其简单易懂,能够直观地展示数据分布。在信号处理中,柱状图可以帮助工程师识别信号中的模式、趋势和异常情况,从而为信号分析和处理提供有价值的见解。 # 2. 柱状图在信号处理中的应用 柱状图在信号处理
recommend-type

用Spring boot和vue写一个登录注册界面

好的,这是一个比较常见的技术问题,我可以为您提供一些参考资料和思路。首先,您可以使用Spring Boot作为后端框架来处理用户认证和注册的逻辑,比如使用Spring Security实现用户登录认证。同时,您还需要设计相应的数据模型和数据库表结构来存储用户信息。在前端方面,您可以使用Vue.js作为框架来构建登录注册页面,使用Axios来发起API请求并和后端进行交互。当然,在实现过程中,还需要考虑一些具体细节,比如数据校验、安全性和用户体验等方面。希望这些信息能够帮助到您。
recommend-type

JSBSim Reference Manual

JSBSim参考手册,其中包含JSBSim简介,JSBSim配置文件xml的编写语法,编程手册以及一些应用实例等。其中有部分内容还没有写完,估计有生之年很难看到完整版了,但是内容还是很有参考价值的。