擅长:python、mysql、java
<p>在写入输出之前,可以使用<code>regexp_replace</code>将所有列中的单引号替换为双引号:</p>
<pre><code>import pyspark.sql.functions as F
df2 = df.select([F.regexp_replace(c, "'", '"').alias(c) for c in df.columns])
# then write output
# df2.coalesce(1).write(...)
</code></pre>