update

26a8bd12 · litaolemo · 0b077f72 · 26a8bd12
Commit 26a8bd12 authored Sep 23, 2020 by litaolemo
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 3 deletions

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

No files found.
--- a/task/spark_test.py
+++ b/task/spark_test.py
@@ -81,9 +81,7 @@ spark.sql("CREATE TEMPORARY FUNCTION arrayMerge AS 'com.gmei.hive.common.udf.UDF

 sql_search_ctr = r"""
 SELECT
-        cl_id,
-        card_id,
-        count(distinct app_session_id) as session_pv
+        count(1)
        from
        (
           SELECT