在scala中沿属性拆分或分解多维数组

xfb7svmp 于 2021-05-27 发布在 Spark

关注(0)|答案(1)|浏览(444)

var date_columns = df.dtypes.filter(_._2 == "TimestampType")

这将创建一个仅包含时间戳类型列名及其datatepyes的二维数组
array[（string，string）]=数组（（cutoffdate，timestamptype），（wrk\u pkg\u start\u date，timestamptype），（wrk\u pkg\u end\u date，timestamptype））
现在，如何拆分这个数组，使数组中只有列名
datecolumns=[截止日期， Package 开始日期， Package 结束日期]
在斯卡拉Spark。请不要使用for循环

scala apache-spark Arrays

来源：https://stackoverflow.com/questions/63278664/splitting-or-breakup-multidimensional-arrays-in-scala-spark-along-attributes

1条答案

按热度按时间

pes8fvy91#

只是使用 collect 为了这个

var date_columns = df.dtypes.collect{ case (name, "TimestampType") => name }
``` `collect` 可以 `filter` 使用模式匹配和 `map` 元素
请参阅scala文档

赞(0）回复(0）举报 2021-05-27

我来回答

在scala中沿属性拆分或分解多维数组

1条答案

相关问题

热门标签

最新问答