withMetadata

Returnerar en ny DataFrame genom att uppdatera en befintlig kolumn med metadata.

Syntax

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

Parameters

Parameter Type Beskrivning
columnName str sträng, namnet på den befintliga kolumnen för att uppdatera metadata.
metadata Dict dict, nya metadata som ska tilldelas till df.schema[columnName].metadata.

Retur

DataFrame: DataFrame med uppdaterad metadatakolumn.

Exempel

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