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 actualizando una columna existente con metadatos.
Sintaxis
withMetadata(columnName: str, metadata: Dict[str, Any])
Parámetros
| Parámetro | Tipo | Descripción |
|---|---|---|
columnName |
str | string, nombre de la columna existente para actualizar los metadatos. |
metadata |
diccionario | dict, nuevos metadatos que se asignarán a df.schema[columnName].metadata. |
Devoluciones
DataFrame: DataFrame con la columna de metadatos actualizada.
Ejemplos
df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
df_meta = df.withMetadata('age', {'foo': 'bar'})
df_meta.schema['age'].metadata
# {'foo': 'bar'}