update

task/spark_test.py

@@ -154,7 +154,7 @@ print(huidu_device_id_sql)
 huidu_device_id_df = spark.sql(huidu_device_id_sql)
 huidu_device_id_df.createOrReplaceTempView("dev_view")
 sql_search_ctr = r"""
-SELECT query,count(query) as count_query,search_pv,search_uv
+SELECT query,search_pv,search_uv
 	FROM
 	(
 		SELECT query
@@ -255,7 +255,7 @@ SELECT query,count(query) as count_query,search_pv,search_uv
 		)t2
 		on t1.cl_id=t2.device_id AND t1.partition_date = t2.partition_date
 		GROUP BY query
-		)
+		) order by search_pv desc limit 200
 """.format(start_date='20201024',end_date='20201025')
 
 print(sql_search_ctr)