首先以spark的本地模式测试spark API,以local的方式运行spark-shell:web
先从parallelize入手吧:shell
map操做后结果:编程
下面看下 filter操做:函数式编程
filter执行结果:函数
咱们用最正宗的scala函数式编程的风格:测试
执行结果:spa
从结果 能够看出来,与以前那种分步奏方式结果是同样的scala
但采用这种方式,便是复合scala风格的写法,也是符合spark的应用程序风格的写法,在spark的编程中,大多数功能的实现都是只要一行代码便可完成。orm