withColumnsRenamed

Renvoie un nouveau DataFrame en renommant plusieurs colonnes. Ceci est une opération sans effet si le schéma ne contient pas les noms de colonne donnés.

Syntaxe

withColumnsRenamed(colsMap: Dict[str, str])

parameter

parameter	Type	Description
colsMap	dict	Un dictionnaire des noms de colonne existants et des noms de colonne souhaités correspondants. Actuellement, seule une seule carte est prise en charge.

parameter	Type	Description
colsMap	dict	Un dictionnaire des noms de colonne existants et des noms de colonne souhaités correspondants. Actuellement, seule une seule carte est prise en charge.

Renvoie

DataFrame: DataFrame avec des colonnes renommées.

Exemples

Python

df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])

df.withColumnsRenamed({"age": "age2"}).show()
# +----+-----+
# |age2| name|
# +----+-----+
# |   2|Alice|
# |   5|  Bob|
# +----+-----+

df.withColumnsRenamed({"age": "age2", "name": "name2"}).show()
# +----+-----+
# |age2|name2|
# +----+-----+
# |   2|Alice|
# |   5|  Bob|
# +----+-----+

df.withColumnsRenamed({"non_existing": "new_name"}).show()
# +---+-----+
# |age| name|
# +---+-----+
# |  2|Alice|
# |  5|  Bob|
# +---+-----+