代码之家 › 专栏 › 技术社区 › Shankar Panda

如何从org.apache.spark.sql获取密钥。在scala中键入列并将其放入列表变量中?

apache-spark-sql apache-spark scala

Shankar Panda · 技术社区 · 1 年前

我正试图从org.apache.spark.sql获取密钥。列类型变量并将其放入列表中,这样我就可以进行一些模式比较。

inputFieldMap: org.apache.spark.sql.Column = keys:[customerID,country],values[customerID,country]

expected output
newvariable: list[string]=[customerID,country];

1 回复 | 直到 1 年前

s.polam 1 年前

使用 map_keys 从的列获取列表键的函数 map 数据类型。

df.selectExpr("map_keys(inputFieldMap) as newvariable")

推荐文章

Wickoo · Scala变量解析:类与局部变量

3 月前

Jake · 如何回滚臭鼬事务以进行集成测试?(缺少隐式原点)

5 月前

user79074 · 如何立即执行未来

5 月前

david.perez · 迁移到Scala 3后,我收到以下警告:纯表达式在语句位置什么也不做

10 月前

Isaac Zahau · 有没有办法修复删除转义符的无效JSON记录?

1 年前

Readren · 如何定义标量。标量3中元组的ValueOf?

1 年前

Shankar Panda · 如何从org.apache.spark.sql获取密钥。在scala中键入列并将其放入列表变量中?

1 年前

Shankar Panda · 如何在scala数据帧中分解两个数组列?

1 年前

Mandroid · 代码导航不适用于intellij中的scala文件

1 年前

Leif Andersen · “=>”在scala泛型中是什么意思?

1 年前