iT邦幫忙

2023 iThome 鐵人賽

DAY 16
0
AI & Data

30天胡搞瞎搞學會pyspark系列 第 16

[ Day 16 ] - Pyspark | 資料轉換 - Column : withColumnRenamed()

  • 分享至 

  • xImage
  •  

今天是中秋連假的最後一天,還是好好的堅持著的我,對自己感到感動XD
希望可以好好堅持到最後一天吧
今天要介紹的是這個function,其實跟昨天的withColumn()很類似,不過今天的重點會放在Rename上面
今天這個function就非常的單純,主要就是將重點放在rename上面!
那就開始囉!

1. 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+---------+---+------------+
'''

2. withColumnsRenamed()

需要將你的Pyspark版本升級至3.4以上才能夠使用


上一篇
[ Day 15 ] - Pyspark | 資料轉換 - Column : withColumn()
下一篇
[ Day 17 ] - Pyspark | 資料集合 - Spark 7 種 Join
系列文
30天胡搞瞎搞學會pyspark30
圖片
  直播研討會
圖片
{{ item.channelVendor }} {{ item.webinarstarted }} |
{{ formatDate(item.duration) }}
直播中

尚未有邦友留言

立即登入留言