首页 > 解决方案 > 在胶水动态框架中更改嵌套字段名称

问题描述

我有一个具有以下模式的胶水动态框架。

root
|-- grade: struct
|    |-- num: string
|-- name: struct
|    |-- first: string

我想将 num 的名称更改为 score。我使用 rename_field 函数。

df = df.rename_field("grade.num", "grade.score")

但该方法似乎不起作用。我知道使用 cast 函数的 spark 解决方案,但是有什么方法可以使用胶水动态框架?使用动态框架内置函数甚至可以更改嵌套列的名称吗?

标签: amazon-web-servicesapache-sparkpysparkapache-spark-sqlaws-glue

解决方案


推荐阅读