标签：之求 arr val Int toInt DataSet 总分 六百 data

package com.sjw.flink

import org.apache.flink.api.scala._
import org.apache.flink.core.fs.FileSystem.WriteMode

object Score {

def main(args: Array[String]): Unit = {
//批处理环境
val env = ExecutionEnvironment.getExecutionEnvironment
env.setParallelism(1)
//读取数据
val dataDS: DataSet[String] = env.readTextFile("src/main/resources/score.txt")
//封装样例类
val linesDS: DataSet[ScoreTest] = dataDS.map(data => {
val arr: Array[String] = data.split(",")
ScoreTest(arr(0).toInt, arr(1).toInt, arr(2).toInt, arr(3).toInt, arr(4).toInt, arr(5).toInt)
})

val filterDS: DataSet[ScoreTest] = linesDS.filter(data =>(data.A>=60 && data.B>=60 && data.C>=60 && data.D>=60 && data.E>=60))
val sumDS: DataSet[(Int, Int)] = filterDS.map(x => {
var sum = x.A + x.B + x.C + x.D + x.E
(x.id, sum)
})
val result: DataSet[Int] = sumDS.filter(_._2>=600).map(_._1)

// result.print()
result.writeAsText("D:\\workspace\\fink_demo\\src\\main\\resources\\id1.txt",WriteMode.NO_OVERWRITE)

env.execute()

}
}

//样例类
case class ScoreTest(id:Int,A:Int,B:Int,C:Int,D:Int,E:Int)

标签：之求,arr,val,Int,toInt,DataSet,总分,六百,data
来源： https://www.cnblogs.com/whyuan/p/13276905.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。