avec métadonnées

Retourne un nouveau DataFrame en mettant à jour une colonne existante avec des métadonnées.

Syntaxe

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

parameter

parameter	Type	Description
columnName	str	Chaîne, nom de la colonne existante pour mettre à jour les métadonnées.
metadata	dict	dictionnaire, nouvelles métadonnées à attribuer à df.schema[columnName].metadata.

parameter	Type	Description
columnName	str	Chaîne, nom de la colonne existante pour mettre à jour les métadonnées.
metadata	dict	dictionnaire, nouvelles métadonnées à attribuer à df.schema[columnName].metadata.

Renvoie

DataFrame: DataFrame avec colonne de métadonnées mise à jour.

Exemples

Python

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