spark複習二:Broadcast廣播變量和accumulator累加器

1.shared variable共享變量: scala> val kvphone=sc.parallelize(List((1,"iphone"),(2,"xiaomi"),(3,"oppo"),(4,"huawei"))) kvphone: org.apache.spark.rdd.RDD[(Int, String)] = ParallelCollectionRDD[0] at paralle
相關文章
相關標籤/搜索