Condividi tramite


withField

Aggiungere o sostituire un campo in una colonna struct.

Sintassi

withField(fieldName, col)

Parametri

Parametro Tipo Descrizione
fieldName str Nome del campo da aggiungere o sostituire
col colonna Espressione di colonna per il valore del campo

Restituzioni

colonna

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|
# +---+