update

eda/smart_rank/dist_periodic_update_smart_rank.py

@@ -163,8 +163,8 @@ if __name__ == '__main__':
             device_ids_rdd = spark.sparkContext.parallelize(device_ids)
             result = device_ids_rdd.repartition(40).map(
                 lambda x: update_device_smart_rank(str(x, encoding='utf-8'), result_all_dict,
-                                                   service_detail_view_count_30_dict, result_smart_rank_score_dict)).toDF()
-            result.show()
+                                                   service_detail_view_count_30_dict, result_smart_rank_score_dict))
+            result.foreach(print)
             print(time.time() - start)
     except Exception as e:
         print(e)
\ No newline at end of file