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
相关文章
相关标签/搜索