withField

Dodaj lub zastąp pole w kolumnie struktury.

Składnia

withField(fieldName, col)

Parametry

Parameter Typ Opis
fieldName str Nazwa pola do dodania lub zastąpienia
col Kolumna Wyrażenie kolumny dla wartości pola

Zwroty

Kolumna

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