1. 程式人生 > >python語言 pyspark中dataframe修改列名

python語言 pyspark中dataframe修改列名

這裡給出在spark中對dataframe修改列名。

df = sqlContext.read.parquet("/user/使用者名稱/123.parquet")

##########df資料例項

linkPh     ph

123        456

##########把列名分別修改為name和value

df.selectExpr("linkPh as name","ph as value").show()

##########新df資料顯示

name    value

1234     456


這裡使用了RDD操作函式selectExpr,具體該函式的引數說明可以去檢視文件。

有任何問題想跟我交流,請加qq群636866908(Python&大資料)與我聯絡,或者加qq群456726635(R語言&大資料分析)也可。