Notitie
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen u aan te melden of de directory te wijzigen.
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen de mappen te wijzigen.
Een veld in een structkolom toevoegen of vervangen.
Syntaxis
withField(fieldName, col)
Parameterwaarden
| Kenmerk | Typ | Beschrijving |
|---|---|---|
fieldName |
str | Naam van het veld dat moet worden toegevoegd of vervangen |
col |
Rubriek | Kolomexpressie voor de veldwaarde |
Retouren
Rubriek
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|
# +---+