Spark学习进度10-DS&DF基础操作

有类型操作 flatMap

通过 flatMap 可以将一条数据转为一个数组, 后再展开这个数组放入 Dataset

val ds1=Seq("hello spark","hello hadoop").toDS() ds1.flatMap(item => item.split(" ")).show()

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/wsffdx.html