重命名数据框pyspark中的列添加字符串

Question

我使用 Pandas 在 Python 中编写了代码，将“VEN_”添加到列名称的开头：

Tablon.columns = "VEN_" + Tablon.columns

它工作正常，但现在我正在使用 PySpark，但它不起作用。我试过了：

Vaa_total.columns = ['Vaa_' + col for col in Vaa_total.columns]

或者

for elemento in Vaa_total.columns:
    elemento = "Vaa_" + elemento

还有其他类似的事情，但它不起作用。

我不想替换列名称，我只想保留它，但在开头添加一个字符串。

Answer 1

尝试这样的事情：

for elemento in Vaa_total.columns:
    Vaa_total =Vaa_total.withColumnRenamed(elemento, "Vaa_" + elemento)