网站建设会计处理,没封的网址免费兄弟,教务系统管理系统入口,网站是否有管理员权限在Scala中#xff0c;您可以以串行和并行的方式提交Spark作业。看看如何使用for和par.foreach构造对应的例子。
串行Spark作业#xff08;使用for#xff09;
// 串行Spark作业设置
for (tag - tags) {spark.sparkContext.setJobGroup(tag.toString, sTag: $tag…在Scala中您可以以串行和并行的方式提交Spark作业。看看如何使用for和par.foreach构造对应的例子。
串行Spark作业使用for
// 串行Spark作业设置
for (tag - tags) {spark.sparkContext.setJobGroup(tag.toString, sTag: $tag)// 为每个标签执行Spark操作
}并行Spark作业使用par.foreach
// 并行Spark作业设置
tags.par.foreach { tag spark.sparkContext.setJobGroup(tag.toString, sTag: $tag)// 并行执行每个标签的Spark操作
}关键区别
for用于顺序处理而par.foreach允许并行处理。
