2个回答
kidd23的方法比较麻烦，直接用withColumnRenamed就行了
new_df = df.withColumnRenamed('old_name', 'new_name')
mrhust
2019-02-19 12:03
假如你要把df中一个叫old_col的列改成new_col，可以用以下的代码，其他列则不改变
import pyspark.sql.functions as F
new_df = (df
.select(*[F.col(s).alias(new_col) if s == old_col else s for s in df.columns]))
kidd23
2018-06-21 08:37
相关讨论
随便看看