- 链接地址：https://blog.csdn.net/fjr_huoniao/article/details/51417523
- 链接标题：spark flatmap_spark flatmap func自定义-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：2556
文章浏览阅读2.4k次。flatMap算子，在java中，接收的参数是FlatMapFunction,我们需要自己定义FlatMapFunction的第二个泛型类型，即，代表了返回的新元素的类型 call()方法，返回的类型，不是U，而是Iterable，这里的U也与第二个泛型类型相同 flatMap其实就是，接收原始RDD中的每个元素，并进行各种逻辑的计算和处理，返回可以返回多个元素_spark flatmap func自定义
版权声明：本文发布于特牛网址导航 内容均来源于互联网 如有侵权联系删除
