RDD操做续

文章目录 map和flatmap join 使用Spark Core进行词频统计 subtract 减法求子集 intersection 求交集 cartesian:笛卡尔积 takeOrdered takeSample sample countByKey mapPartitions foreach map和flatmap scala> val nums = sc.parallelize(List
相关文章
相关标签/搜索