列名変更

複数の列の名前を変更して、新しいDataFrameを返します。 スキーマに指定された列名が含まれていない場合、この処理は実行されません。

構文

withColumnsRenamed(colsMap: Dict[str, str])

パラメーター

パラメーター	Type	説明
colsMap	辞書	既存の列名と、それに対応する希望する列名をまとめた辞書。現在サポートされているマップは1つのみです。

戻り値

DataFrame列名が変更されたDataFrame 。

例

Python

df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])

df.withColumnsRenamed({"age": "age2"}).show()
# +----+-----+
# |age2| name|
# +----+-----+
# |   2|Alice|
# |   5|  Bob|
# +----+-----+

df.withColumnsRenamed({"age": "age2", "name": "name2"}).show()
# +----+-----+
# |age2|name2|
# +----+-----+
# |   2|Alice|
# |   5|  Bob|
# +----+-----+

df.withColumnsRenamed({"non_existing": "new_name"}).show()
# +---+-----+
# |age| name|
# +---+-----+
# |  2|Alice|
# |  5|  Bob|
# +---+-----+