如何使用scala从dataframe获取字符串列的最大长度？

发布时间：2020-12-16 18:19:09 所属栏目：安全来源：网络整理

导读：这可能是一个非常简单的问题.我使用Spark 1.6与 scala var DF=hivecontext.sql("select name from myTable")val name_max_len =DF.agg(max(length($"name"))) // did not workprintln(name_max_len) 我怎样才能获得最大长度？谢谢侯赛因解决方法你应该收

这可能是一个非常简单的问题.我使用Spark 1.6与 scala

var DF=hivecontext.sql("select name from myTable")
val name_max_len =DF.agg(max(length($"name"))) // did not work

println(name_max_len)

我怎样才能获得最大长度？

谢谢
侯赛因

解决方法

你应该收集结果：

val df = Seq("foo","bar","foobar").toDF("name")
df.agg(max(length($"name"))).as[Int].first

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!