Spark - TypeError：'str'和'int'的实例之间不支持'<='

Question

我正在尝试执行以下代码：

df2.groupBy(df2.item_type,df2.product_id)\
    .count()\
    .where(f.col('row' =<3))\
    .withColumn('row',f.row_number().over(\
    Window.partitionBy("item_type")\
    .orderBy(f.col('count')))).show() 

但是我遇到了这个错误：TypeError: '

Answer 1

where 子句中的语法错误

...
.where(f.col('row') <= 3)
...

我无法添加评论。 将row 替换为您需要过滤的column name 的名称。

f.col('row') 应替换为f.col('column_name_you_want_to_filter')。例如：f.col('product_id')。

Answer 2

我认为 'row' 是一个字符串