メインコンテンツまでスキップ

列を含む

複数の列を追加するか、同じ名前の既存の列を置き換えることで、新しいDataFrameを返します。

構文

withColumns(*colsMap: Dict[str, Column])

パラメーター

パラメーター

Type

説明

colsMap

辞書

列名と列の辞書。現在サポートされているマップは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|
# +---+-----+----+----+
このページの見出し