列名変更
既存の列の名前を変更して、新しいDataFrameを返します。 スキーマに指定された列名が含まれていない場合、これは何も実行されません。
構文
withColumnRenamed(existing: str, new: str)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
| str | 名前を変更する既存の列の名前。 |
| str | 列に割り当てる新しい名前。 |
戻り値
DataFrame: 列名が変更された新しいDataFrame 。
例
Python
df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
df.withColumnRenamed("age", "age2").show()
# +----+-----+
# |age2| name|
# +----+-----+
# | 2|Alice|
# | 5| Bob|
# +----+-----+
df.withColumnRenamed("non_existing", "new_name").show()
# +---+-----+
# |age| name|
# +---+-----+
# | 2|Alice|
# | 5| Bob|
# +---+-----+
df.withColumnRenamed("age", "age2").withColumnRenamed("name", "name2").show()
# +----+-----+
# |age2|name2|
# +----+-----+
# | 2|Alice|
# | 5| Bob|
# +----+-----+