withMetadata

Vrátí nový datový rámec aktualizací existujícího sloupce s metadaty.

Syntaxe

withMetadata(columnName: str, metadata: Dict[str, Any])

Parametry

Parameter Typ Description
columnName str řetězec, název existujícího sloupce pro aktualizaci metadat.
metadata slovník diktování, nová metadata, která mají být přiřazena df.schema[columnName].metadata.

Návraty

DataFrame: Datový rámec s aktualizovaným sloupcem metadat.

Příklady

df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
df_meta = df.withMetadata('age', {'foo': 'bar'})
df_meta.schema['age'].metadata
# {'foo': 'bar'}