如何将列添加到架构的开头?

erw*_*man 6 scala apache-spark apache-spark-sql

Dataset.withColumn()似乎将列附加到架构的末尾.如何将列添加到架构的开头?

hi-*_*zir 12

select与通配符一起使用:

df.select(new_column, col("*"))
Run Code Online (Sandbox Code Playgroud)

  • 这会添加一个重复列。您可以在创建 new_column 之前将通配符替换为列名: `current_columns = df.schema.names` `df = df.withColumn(new_column, ...)` **`df = df.select.([new_column ]+当前列)`** (3认同)