首页 > 代码库 > Spark API编程动手实战-01-以本地模式进行Spark API实战map、filter和co
Spark API编程动手实战-01-以本地模式进行Spark API实战map、filter和co
首先以spark的本地模式测试spark API,以local的方式运行spark-shell:
先从parallelize入手吧:
map操作后结果:
下面看下 filter操作:
filter执行结果:
我们用最正宗的scala函数式编程的风格:
执行结果:
从结果 可以看出来,与之前那种分步奏方式结果是一样的
但采用这种方式,即是复合scala风格的写法,也是符合spark的应用程序风格的写法,在spark的编程中,大多数功能的实现都是只要一行代码即可完成。
Spark API编程动手实战-01-以本地模式进行Spark API实战map、filter和co
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。