update

task/spark_test.py

@@ -93,14 +93,9 @@ spark.sql("CREATE TEMPORARY FUNCTION arrayMerge AS 'com.gmei.hive.common.udf.UDF
 # huidu_device_id_df = spark.sql(huidu_device_id_sql)
 # huidu_device_id_df.createOrReplaceTempView("dev_view")
 sql_search_ctr = r"""
-SELECT query
-     , coalesce(t3.all_search_uv, 0) as all_search_uv --全部搜索uv
-     , coalesce(t3.all_search_pv, 0) as all_search_pv --全部搜索pv
-     , t3.partition_date
-FROM (
          --搜索pvuv
-         SELECT query
-              , click.partition_date        as partition_date
+         SELECT 
+              click.partition_date        as partition_date
               , count(click.cl_id)          as all_search_pv
               , count(distinct click.cl_id) as all_search_uv
          FROM (
@@ -197,8 +192,8 @@ FROM (
                     AND params['card_type'] = 'highlight_word'
               ) click
 
-         GROUP BY click.partition_date, query
-     ) t3 order by all_search_uv asc
+         GROUP BY click.partition_date
+
 
 """.format(start_date='20201116',end_date='20201117')