withMetadata

Mengembalikan DataFrame baru dengan memperbarui kolom yang sudah ada dengan metadata.

Sintaksis

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

Parameter-parameternya

Parameter Tipe Deskripsi
columnName str string, nama kolom yang ada untuk memperbarui metadata.
metadata kamus dict, metadata baru yang akan ditetapkan ke df.schema[columnName].metadata.

Pengembalian Barang

DataFrame: DataFrame dengan kolom metadata yang diperbarui.

Examples

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