rootk all 排序公式

alg_recsys_rank_item_realtime_1hrootall.py

@@ -59,8 +59,8 @@ def get_sql(partition, project):
     sql = '''
     SELECT  videoid
             ,CONCAT_WS(',',COLLECT_LIST(CONCAT(time,":",exp))) AS exp
-            ,CONCAT_WS(',',COLLECT_LIST(CONCAT(time,":",exp))) AS share
-            ,CONCAT_WS(',',COLLECT_LIST(CONCAT(time,":",exp))) AS return
+            ,CONCAT_WS(',',COLLECT_LIST(CONCAT(time,":",share))) AS share
+            ,CONCAT_WS(',',COLLECT_LIST(CONCAT(time,":",return))) AS return
     FROM    (
                 SELECT  videoid
                         ,time