spark core 入门实战之二(RDD的练习)

有如下几种方式建立RDDspa #经常使用Transformation(即转换,延迟加载)scala#经过并行化scala集合建立RDD val rdd1 = sc.parallelize(Array(1,2,3,4,5,6,7,8)) #查看该rdd的分区数量 rdd1.partitions.length val rdd1 = sc.parallelize(List(5,6,4,7,3,8,2,
相关文章
相关标签/搜索