首先以spark的本地模式测试spark API,以local的方式运行spark-shell:


先从parallelize入手吧:


map操作后结果:

下面看下 filter操作:

filter履行结果:

我们用最正宗的scala函数式编程的风格:

履行结果:

从结果 可以看出来,与之前那种分步奏方式结果是1样的
但采取这类方式,即是复合scala风格的写法,也是符合spark的利用程序风格的写法,在spark的编程中,大多数功能的实现都是只要1行代码便可完成。
上一篇 ssh自动登录工具
下一篇 Notification用法