denganField

Menambahkan atau mengganti bidang dalam kolom struct.

Sintaksis

withField(fieldName, col)

Parameter-parameternya

Parameter	Tipe	Deskripsi
fieldName	str	Nama bidang yang akan ditambahkan atau diganti
col	kolom	Ekspresi kolom untuk nilai bidang

Pengembalian Barang

kolom

Examples

from pyspark.sql import Row
from pyspark.sql.functions import lit
df = spark.createDataFrame([Row(a=Row(b=1, c=2))])
df.withColumn('a', df['a'].withField('b', lit(3))).select('a.b').show()

# +---+
# |  b|
# +---+
# |  3|
# +---+

df.withColumn('a', df['a'].withField('d', lit(4))).select('a.d').show()

# +---+
# |  d|
# +---+
# |  4|
# +---+