擅长:python、mysql、java
<p>试试这个:</p>
<pre><code>df.createTempView('data')
new_df = spark.sqlContext.sql("""
select query
, hrefs
, case when clicked_url='' then '0' else clicked_url end as clicked_url
from data
where array_contains(hrefs, clicked_url) or clicked_url=''
""")
new_df.show()
</code></pre>