今天是中秋連假的最後一天,還是好好的堅持著的我,對自己感到感動XD
希望可以好好堅持到最後一天吧
今天要介紹的是這個function,其實跟昨天的withColumn()
很類似,不過今天的重點會放在Rename上面
今天這個function就非常的單純,主要就是將重點放在rename上面!
那就開始囉!
withColumnRenamed()
主要會用在單純只是在需要幫你的column做Rename上,withColumnRenamed(OldName,NewName)
df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
df.withColumnRenamed('age', 'AGE').show()
'''
+---------+---+------------+Original Data+---------+---+------------+
df.show()
+---+-----+
|age| name|
+---+-----+
| 2|Alice|
| 5| Bob|
+---+-----+
+---------+---+------------+Original Data+---------+---+------------+
+---------+---+------------+OUTPUT+---------+---+------------+
df.withColumnRenamed('age', 'AGE').show()
+---+-----+
|AGE| name|
+---+-----+
| 2|Alice|
| 5| Bob|
+---+-----+
+---------+---+------------+OUTPUT+---------+---+------------+
'''
withColumnsRenamed()
需要將你的Pyspark版本升級至3.4以上才能夠使用