通过使用元数据更新现有列来返回新的 DataFrame。
Syntax
withMetadata(columnName: str, metadata: Dict[str, Any])
参数
| 参数 | 类型 | 说明 |
|---|---|---|
columnName |
str | 字符串，用于更新元数据的现有列的名称。 |
metadata |
dict | dict，要分配给 df.schema[columnName].metadata 的新元数据。 |
退货
DataFrame：具有更新元数据列的数据帧。
示例
df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
df_meta = df.withMetadata('age', {'foo': 'bar'})
df_meta.schema['age'].metadata
# {'foo': 'bar'}