擅长:python、mysql、java
<p>如例外所述-不能将表达式用作关键字,因此:</p>
<pre><code>Row( jsn['column1'] = r[0], jsn['column2'] = r[1])
</code></pre>
<p>不是有效的Python代码。在</p>
<p>您可以使用替代构造函数,然后应用参数:</p>
^{pr2}$
<p>但总的来说,最好是</p>
<pre><code>tmp = spark.read.option("delimiter", "|").csv("testdata")
df = tmp.select(tmp.columns[2:]).toDF(jsn['column1'], jsn['column2'])
</code></pre>