擅长:python、mysql、java
<p>只需使用<code>contains</code>函数就可以做到这一点。有关详细信息,请参阅<a href="https://stackoverflow.com/questions/41889974/filter-df-when-values-matches-part-of-a-string-in-pyspark">this</a>:</p>
<pre><code>from pyspark.sql.functions import col, when
df = df.withColumn('new_Col',when(col('address').contains(col('street_name')),True).otherwise(False))
df.show(truncate=False)
+ + + -+
|address |street_name |new_Col|
+ + + -+
|108 badajoz road north ryde 2113, nsw, australia|north ryde |true |
|25 smart street fairfield 2165, nsw, australia |smart street|true |
+ + + -+
</code></pre>