@boothsun
2019-12-14T16:21:58.000000Z
字数 1828
阅读 5521
大数据
参考文档:scala => 用法 匿名函数
=>
匿名函数,在Spark中函数也是一个对象可以赋值给一个变量。
Spark的匿名函数定义格式:
(形参列表) => {函数体}
所以,=>
的作用就是创建一个匿名函数实例。
比如:(x:Int) => x +1 ,就等同于下面的Java方法:
public int function(int x) {
return x+1;
}
示例:
class Symbol {
var add = (x: Int) => x + 1
}
object test2 {
def main (args: Array[String] ): Unit = {
var symbol = new Symbol
printf(""+ symbol.add.toString())
}
}
循环遍历,示例如下:
var list = Array(1,2,3,4)
for (aa <- list) {
printf(aa+" ")
}
上面代码类似于Java的代码:
int[] list = {1,2,3,4};
for(int aa : list) {
System.out.print(aa+" ");
}
var s:String = "a"
s+="b"
println(s)
s++="c"
println(s)
:::三个冒号运算符表示List的连接操作。(类似于Java中的 list1.addAll(list2)
)
::两个冒号运算符表示普通元素与list的连接操作。(类似于Java中的list1.add(A)
操作)
scala操作示例:
val one = List(1,2,3)
val two = List(4,5,6)
val three = one ::: two
println(three.toString())
val four = 7 :: three
println(four.toString())
scala中元组含义:
scala中元组与数组区别:数组中元素 数据类型必须一样,但是元组数据类型可以不同。
示例程序:
val first = (1,2,3) // 定义三元元组
val one = 1
val two = 2
val three = one -> two
println(three) // 构造二元元组
println(three._2) // 访问二元元组中第二个值
_
可以起到类似于*
作用的通配符:
import org.apache.spark.SparkContext._
例如 遍历集合筛选列表中大于某个值的元素。
val lst = List(1,2,3,4,5)
val lstFilter = lst.filter(_ > 3)
val ss = (1,"22","333")
println(ss._1)
val m = Map(1 -> 2,2 -> 4)
for ((k,_) <- m) println(k) //如果不需要所有部件, 则在不需要的部件使用_; 本例只取key,因此在value处用_
var s:Int=_
def main(args: Array[String]): Unit = {
println(s)
}
def main(args: Array[String]): Unit = {
val s = sum(1 to 5:_*) //把1 to 5当作一个序列处理
println(s)
}
def sum(args: Int*) : Int = {
var result = 0 ;
for(s2 <- args) {
result += s2 ;
}
result ;
}
为可变数组添加元素
val arrBuf1 = new ArrayBuffer[Int]()
arrBuf1+= 11 // 添加一个元素
println(arrBuf1)
从map后者可变数组中移除相应的值
val arrBuf1 = new ArrayBuffer[Int]()
arrBuf1+= 11 // 添加一个元素
arrBuf1+= 12 // 添加一个元素
arrBuf1-= 12 // 删除一个元素
println(arrBuf1)
var map = Map(1 -> 1,2 -> 2,3 ->3 )
map-=1
println(map)