欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Spark API编程动手实战-01-以本地模式进行Spark API实战map、filter和collect

程序员文章站 2022-07-02 17:53:07
...

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

Spark API编程动手实战-01-以本地模式进行Spark API实战map、filter和collect
            
    
    博客分类: spark spark-shellparallelizemapfiltersc 

Spark API编程动手实战-01-以本地模式进行Spark API实战map、filter和collect
            
    
    博客分类: spark spark-shellparallelizemapfiltersc 

先从parallelize入手吧:

Spark API编程动手实战-01-以本地模式进行Spark API实战map、filter和collect
            
    
    博客分类: spark spark-shellparallelizemapfiltersc 

Spark API编程动手实战-01-以本地模式进行Spark API实战map、filter和collect
            
    
    博客分类: spark spark-shellparallelizemapfiltersc 

map操作后结果:

Spark API编程动手实战-01-以本地模式进行Spark API实战map、filter和collect
            
    
    博客分类: spark spark-shellparallelizemapfiltersc 

 

下面看下 filter操作:

Spark API编程动手实战-01-以本地模式进行Spark API实战map、filter和collect
            
    
    博客分类: spark spark-shellparallelizemapfiltersc 

filter执行结果:

Spark API编程动手实战-01-以本地模式进行Spark API实战map、filter和collect
            
    
    博客分类: spark spark-shellparallelizemapfiltersc 

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

Spark API编程动手实战-01-以本地模式进行Spark API实战map、filter和collect
            
    
    博客分类: spark spark-shellparallelizemapfiltersc 

执行结果:

Spark API编程动手实战-01-以本地模式进行Spark API实战map、filter和collect
            
    
    博客分类: spark spark-shellparallelizemapfiltersc 

从结果 可以看出来,与之前那种分步奏方式结果是一样的

但采用这种方式,即是复合scala风格的写法,也是符合spark的应用程序风格的写法,在spark的编程中,大多数功能的实现都是只要一行代码即可完成。