update

eda/smart_rank/dist_update_user_portrait.py

@@ -145,6 +145,7 @@ if __name__ == '__main__':
         result = device_ids_lst_rdd.repartition(100).map(lambda x: get_user_tag_score(x, all_log_df))
         a = result.collect()
         print(a)
+        print(type(a))
         # stat_date = datetime.datetime.today().strftime('%Y-%m-%d')
         # result_last = result_rename.withColumn("stat_date", lit(stat_date))
         # result_last.show()