Update Spark_Transformation和Action算子.md
This commit is contained in:
parent
ee184710cf
commit
c51a4ebd39
@ -73,7 +73,7 @@ sc.parallelize(list).filter(_ >= 10).foreach(println)
|
|||||||
|
|
||||||
### 1.3 flatMap
|
### 1.3 flatMap
|
||||||
|
|
||||||
`flatMap(func)`与`map`类似,但每一个输入的 item 会被映射成 0 个或多个输出的 items( *func* 返回类型需要为`Seq`类型)。
|
`flatMap(func)`与`map`类似,但每一个输入的item会被映射成 0 个或多个输出的items( *func* 返回类型需要为`Seq`)。
|
||||||
|
|
||||||
```scala
|
```scala
|
||||||
val list = List(List(1, 2), List(3), List(), List(4, 5))
|
val list = List(List(1, 2), List(3), List(), List(4, 5))
|
||||||
|
Loading…
x
Reference in New Issue
Block a user