logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

头歌实践答案:Spark RDD编程初级实践、RDD的创建 -Scala、计算BMI指数 、Spark算子综合案例、Spark算子--Scala版本、SparkContext、Spark任务提交

val splitRDD = filteredRDD.map(line => line.split("\\s+", 2))// 按空格拆分,最多拆2个元素(避免姓名/成绩含空格)val key = (arr(0).trim, arr(1).trim, arr(2).trim, arr(3).trim) // 除城市、版本号外的核心字段作为key。.sortBy(elem => (elem._1,

#spark#scala
到底了