Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
Hinzufügen oder Ersetzen eines Felds in einer Strukturspalte
Syntax
withField(fieldName, col)
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
fieldName |
str | Name des Felds, das hinzugefügt oder ersetzt werden soll |
col |
Kolumne | Spaltenausdruck für den Feldwert |
Rückkehr
Kolumne
Beispiele
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|
# +---+