擅长:python、mysql、java
<p>如果坚持使用反斜杠,可以执行以下操作:</p>
<pre><code>from pyspark.sql.functions import col
df = spark.read.csv('/some/path/to/file', sep=',') \
.filter(col('purch_location') == 'BRAMPTON')
</code></pre>
<p>第一次尝试失败,因为括号不平衡</p>
<p>此外,字符串<code>BRAMPTON</code>后面似乎有一些空格,因此您可能希望首先<code>trim</code>列:</p>
<pre><code>from pyspark.sql.functions import col, trim
df = spark.read.csv('/some/path/to/file', sep=',') \
.filter(trim(col('purch_location')) == 'BRAMPTON')
</code></pre>