擅长:python、mysql、java
<p>如果使用其他内容对损坏的列进行检测,然后进行筛选,则它将起作用</p>
<p>您可以这样做:</p>
<pre><code>df.createOrReplaceTempView("df1")
spark.sql("select *, concat('error',malformed_rows) from df1 where concat('error',malformed_rows) is not null").show(10,False)
</code></pre>