update

6c4dd0d6 · litaolemo · 3185da2b · 6c4dd0d6
Commit 6c4dd0d6 authored Nov 06, 2020 by litaolemo
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

spark_test.py task/spark_test.py +1 -1

No files found.
--- a/task/spark_test.py
+++ b/task/spark_test.py
@@ -153,7 +153,7 @@ select count(1),avg(session_pv),avg(session_pv2) from (SELECT  partition_date,
                      app_session_id
            )a
            LATERAL VIEW explode (a.recommend_type) v as recommend_type
-            group by partition_date,card_content_type,cl_id,v.recommend_type )
+            group by partition_date,card_content_type,cl_id,v.recommend_type ) having  session_pv2 >0
 """.format(start_date='20201018',end_date='20201025')

 print(sql_search_ctr)