透過更新現有欄位並加入元資料,回傳新的 DataFrame。
語法
withMetadata(columnName: str, metadata: Dict[str, Any])
參數
| 參數 | 類型 | 說明 |
|---|---|---|
columnName |
str | string,現有欄位名稱,用來更新元資料。 |
metadata |
dict | dict,將新指派到df.schema[columnName].metadata。 |
退貨
DataFrame: DataFrame 並更新了元資料欄位。
Examples
df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
df_meta = df.withMetadata('age', {'foo': 'bar'})
df_meta.schema['age'].metadata
# {'foo': 'bar'}