Apache Spark 将列值提取为整数

ocebsuys 于 2023-08-06 发布在 Apache

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

我有一个看起来像这样的函数：

static Column getFormattedData(Column name, Column surname) {
        return concat(
                lit("NAME_")
                lpad(name,  greatest(length(name), lit(8)), "0"),
                lpad(surname, greatest(length(surname), lit(8)), "0"));
    }

字符串
在lpad()步骤有问题，其中greatest()返回一个Column，而lpad()期望第二个参数是Integer。
有没有办法将列的值提取为整数形式？
或者，是否有更好的方法来格式化这两列/它们的值？
编辑：按要求输入样本：
例如name: Joe和surname: Thomas
输出：NAME_00000JOE_00THOMAS
(both名和姓填充为8个字符）
例如name: Leonardo和surname: DaCaprio
输出：NAME_LEONARDO_DaCaprio
(both姓名>= 8个字母，因此不需要填充）。

apache-spark

来源：https://stackoverflow.com/questions/76704334/extract-column-value-into-integer

1条答案

按热度按时间

0sgqnhkj1#

请检查下面的代码

scala> df.show(false)
+--------+--------+
|name    |surname |
+--------+--------+
|Joe     |Thomas  |
|Leonardo|DaCaprio|
+--------+--------+

scala> :paste
// Entering paste mode (ctrl-D to finish)

df
.select(
    concat(
        lit("NAME_"),
        lpad(upper($"name"), 8, "0"),
        lit("_"),
        lpad(upper($"surname"), 8, "0")
    ).as("output")
)
.show(false)

// Exiting paste mode, now interpreting.

+----------------------+
|output                |
+----------------------+
|NAME_00000JOE_00THOMAS|
|NAME_LEONARDO_DACAPRIO|
+----------------------+

字符串

赞(0）回复(0）举报 2023-08-06

我来回答

Apache Spark 将列值提取为整数

1条答案

相关问题

热门标签

最新问答