小编Kis*_*mar的帖子

从映射中获取列值的值作为 spark 数据帧中的键

我要从列值的映射中获取一个值作为键并创建一个新列

我已经尝试了以下

val testMap = Map("abc" -> "1234", "xyz" -> "3456")

def checkthemap (testmap: Map[String, String], key: String) : String = {
    val value = testmap.get(key)
    if (value == null) "" else value.toString
}

val testDF = analysis
    .withColumn("test", lit(checkthemap(testMap,$"col")))
Run Code Online (Sandbox Code Playgroud)

方法接受字符串而不是列。如何更改我的 withColumn 语句以将列值作为字符串发送到方法。

scala dataframe apache-spark

5
推荐指数
2
解决办法
9551
查看次数

标签 统计

apache-spark ×1

dataframe ×1

scala ×1