scala – Spark数据帧将列值转换为字符串变量

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

导读：我正在尝试将列值提取到变量中,以便我可以在代码中的其他位置使用该值.我想尝试以下几点 val name= test.filter(test("id").equalTo("200")).select("name").col("name") 它回来了 name org.apache.spark.sql.Column = name 如何获得价值？解决方法 col(“n

我正在尝试将列值提取到变量中,以便我可以在代码中的其他位置使用该值.我想尝试以下几点

val name= test.filter(test("id").equalTo("200")).select("name").col("name")

它回来了

name org.apache.spark.sql.Column = name

如何获得价值？

解决方法

col(“name”)为您提供Column类型数据.如果要从列“name”中提取数据,只需执行相同的操作而不使用col(“name”)：

val names = test.filter(test("id").equalTo("200"))
                .select("name")
                .collectAsList() // returns a List[Row]

然后,对于一行,您可以在String中获取名称：

val name = row.getString(0)

（编辑：李大同）

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