複数の列を追加するか、同じ名前の既存の列を置き換えることで、新しい DataFrame を返します。
構文
withColumns(*colsMap: Dict[str, Column])
パラメーター
| パラメーター | タイプ | 説明 |
|---|---|---|
colsMap |
辞書 | 列名と列のディクテーション。 現時点では、1 つのマップのみがサポートされています。 |
返品
DataFrame: 新しい列または置き換えられた列を含む DataFrame。
例示
df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
df.withColumns({'age2': df.age + 2, 'age3': df.age + 3}).show()
# +---+-----+----+----+
# |age| name|age2|age3|
# +---+-----+----+----+
# | 2|Alice| 4| 5|
# | 5| Bob| 7| 8|
# +---+-----+----+----+