pyspark sql降序排列

以下是使用pyspark sql进行降序排列的示例代码：

from pyspark.sql.window import Window
from pyspark.sql.functions import rank, col

# 创建窗口
window = Window.partitionBy(df['xx1']).orderBy(df['score'].desc())

# 使用窗口函数进行排序
aid_aidlist_df = df.select('*', rank().over(window).alias('rank')) \
                   .filter(col('rank') <= 50)

# 输出结果
aid_aidlist_df.show()

在这个示例中，我们首先导入了`Window`和`rank`函数。然后，我们创建了一个窗口，该窗口按照`xx1`分区，并按照`score`字段进行降序排列。接下来，我们使用`rank`函数将每个行分配一个排名，并将结果存储在`rank`列中。最后，我们使用`filter`函数过滤出排名小于等于50的行，并将结果存储在`aid_aidlist_df`中。最后，我们使用`show`函数输出结果。