withColumn (oszlopHozzáad)

Új DataFrame-et ad vissza egy oszlop hozzáadásával vagy az azonos nevű meglévő oszlop lecserélésével.

Szemantika

withColumn(colName: str, col: Column)

Paraméterek

Paraméter Típus Leírás
colName str sztring, az új oszlop neve.
col oszlop az új oszlop oszlopkifejezése.

Visszatérítések

DataFrame: DataFrame új vagy lecserélt oszlopmal.

Jegyzetek

Ez a módszer belső előrejelzést vezet be. Ezért, ha többször hívjuk meg, például hurkokon keresztül, hogy több oszlopot adjunk hozzá, nagy terveket hozhat létre, amelyek teljesítményproblémákat okozhatnak, sőt.StackOverflowException Ennek elkerülése érdekében egyszerre több oszlopot használjon select .

Examples

df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
df.withColumn('age2', df.age + 2).show()
# +---+-----+----+
# |age| name|age2|
# +---+-----+----+
# |  2|Alice|   4|
# |  5|  Bob|   7|
# +---+-----+----+