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,
相關文章
相關標籤/搜索