withColumnsRenamed

Devuelve un nuevo dataframe cambiando el nombre de varias columnas. Se trata de un no-op si el esquema no contiene los nombres de columna especificados.

Sintaxis

withColumnsRenamed(colsMap: Dict[str, str])

Parámetros

Parámetro	Tipo	Descripción
colsMap	diccionario	Un dict de los nombres de columna existentes y los nombres de columna deseados correspondientes. Actualmente, solo se admite un solo mapa.

Devoluciones

DataFrame: DataFrame con columnas con nombre cambiado.

Ejemplos

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|
# +---+-----+