列を含む
複数の列を追加するか、同じ名前の既存の列を置き換えることで、新しいDataFrameを返します。
構文
withColumns(*colsMap: Dict[str, Column])
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
| 辞書 | 列名と列の辞書。現在サポートされているマップは1つのみです。 |
戻り値
DataFrame: 新規または置換された列を含むDataFrame 。
例
Python
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|
# +---+-----+----+----+