spark RDD相关总结(一)

Value类型 map(func)案例 做用:返回一个新的RDD,该RDD由每个输入元素通过func函数转换后组成 需求:建立一个1-10数组的RDD,将全部元素2造成新的RDD (1)建立 scala> var source = sc.parallelize(1 to 10) source: org.apache.spark.rdd.RDD[Int] = ParallelCollectionRD
相关文章
相关标签/搜索