withField

Добавьте или замените поле в столбце структуры.

Синтаксис

withField(fieldName, col)

Параметры

Параметр	Тип	Описание
fieldName	str	Имя поля для добавления или замены
col	колонна	Выражение столбца для значения поля

Возвраты

колонна

Примеры

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