聚合并排序
user_cnt_df = data.groupBy(“dbt_id”).agg(F.countDistinct(“device_id”).alias(“User_cnt”)).orderBy(F.col(“User_cnt”).desc())
user_cnt_df.show(10,truncate=False)
取前10行数据
user_cnt_top10 = user_cnt_df.head(10)
取出 dbt_id 和 User_cnt 列
dbt_ids = [row[0] for row in user_cnt_top10]
user_cnts = [row[1] for row in user_cnt_top10]
bar_chart(dbt_ids, user_cnts,45,“宋体”,“标题”,“测试”)