Nota:
El acceso a esta página requiere autorización. Puede intentar iniciar sesión o cambiar directorios.
El acceso a esta página requiere autorización. Puede intentar cambiar los directorios.
Devuelve un nuevo dataframe agregando varias columnas o reemplazando las columnas existentes que tienen los mismos nombres.
Sintaxis
withColumns(*colsMap: Dict[str, Column])
Parámetros
| Parámetro | Tipo | Descripción |
|---|---|---|
colsMap |
diccionario | un dict de nombre de columna y Column. Actualmente, solo se admite un solo mapa. |
Devoluciones
DataFrame: DataFrame con columnas nuevas o reemplazadas.
Ejemplos
df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
df.withColumns({'age2': df.age + 2, 'age3': df.age + 3}).show()
# +---+-----+----+----+
# |age| name|age2|age3|
# +---+-----+----+----+
# | 2|Alice| 4| 5|
# | 5| Bob| 7| 8|
# +---+-----+----+----+