Spark Transformation和Action算子速查表

Transformation算子 Transformation算子 做用 map(func) 返回一个新的分布式数据集,其中每一个元素都是由源RDD中每个元素通过func函数转换获得的 filter(func) 返回一个新的数据集,其中包含的元素来自源RDD中元素通过func函数过滤后的结果(func函数返回true的结果) flatMap(func) 相似于map, 可是每一个元素能够映射到0到
相关文章
相关标签/搜索