Cccc杨

导航

spark中的算子

Transformation类型算子:不会定义后立即执行的算子 Actions类型算子:立即执行 1.map算子 把原来的数据用map的自定义形式来切换成新的RDD。 scala> rdd_f1.collect() res32: Array[String] = Array(i am a sutdne

posted on 2021-03-08 15:48  Cccc杨  阅读(234)  评论(0编辑  收藏  举报