在PySpark数据框中创建的二进制列不能用作过滤器？

Question

我正在使用PySpark在我的数据框中创建一个附加的BinaryColumn，然后使用它来过滤该数据框。此过程显示错误。

1. 数据：

Click here to see the data

2. [创建二进制列：

Click here to see the Binary Column

Click here to see the Schema

3. 过滤器和错误：

click here to see the error

Answer 1

尝试使用filter功能

df_filter = df_bc.filter(col('binary_col') == 'false')
df_filter.show()