通过重命名现有列返回新的 DataFrame。 如果架构不包含给定的列名称,则这是一个 no-op。
Syntax
withColumnRenamed(existing: str, new: str)
参数
| 参数 | 类型 | 说明 |
|---|---|---|
existing |
str | 要重命名的现有列的名称。 |
new |
str | 要分配给列的新名称。 |
退货
DataFrame:具有重命名列的新 DataFrame。
示例
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|
# +----+-----+