Spark函数式编程进阶

函数式编程进阶

一、函数和变量同样做为Scala语言的一等公民，函数能够直接复制给变量；

二、函数更长用的方式是匿名函数，定义的时候只须要说明输入参数的类型和函数体便可，不须要名称，可是匿名函数赋值给一个变量（实际上是val常量），Spark源码中大量存在这种语法；

三、函数能够做为参数直接传递给函数，这极大地简化的编程语法；

四、函数式编程一个很是强大的地方之一在于函数的返回值能够是函数,当函数的返回类型是函数的时候，这个时候就是代表Scala的函数是实现了闭包！

Scala壁报的内幕是：Scala的函数背后是类和对象，因此，Scala的参数都作为了对象的成员！因此后续能够继续访问

五、Currying，复杂的函数式编程中常常使用，能够维护变量在内存中的状态，且实现返回函数的链式功能，能够实现很是复杂的算法和逻辑；

1）之前java的防暑是new出一个接口实例，而且在接口实例的同调方法callback中来实现业务逻辑，如今是直接把同调方法callback传递给个人函数，且在函数体中直接使用，这毫无疑问的简化代码的编写，提高了开发的效率；

2）这种方式很是方便编写负责的业务逻辑和控制逻辑，对于图计算，计算机学习，深度学习等相当重要；

函数做为函数的参数传递的编程方式是称之为高阶函数的编程方式，Spark源码和应用程序开发至少60%都是这种代码！

object functionalProgramming{

//一、函数和变量同样做为Scala语言的一等公民，函数能够直接复制给变量

def mian（args：Array【String】）；Unit={

val hiData = hiBigData -

hiDAta("Spark")

val f = (name:String)=>println("Hi,"+name)

f("Kafka")

def getName(func:(String)=>Unit,name:String){

func(name)

}

getName(f,"Scala")

Array(1 to 10: *).map{(item:Int)=>2*item}.foreach{x=>println(x)}

def funResult(message:String) = (name:String)=>println(message +":"+name)

funcResult("Hello")("Java")

val result=funcResult("Hello")

result("Java")

}

def hiBIgData(name:String){

println("Hi,"+name)

}

 

 

 

 

.