dist test

eda/esmm/Model_pipline/dist_predict.py

@@ -282,13 +282,13 @@ if __name__ == "__main__":
             lambda l: Row(sample_id=l.split(":")[0],uid=l.split(":")[1],city=l.split(":")[2],cid_id=l.split(":")[3],ctcvr=l.split(":")[4])))
 
         nearby_data = te_result_dataframe.toPandas()
-        nearby_data.show()
+        nearby_data.head()
 
 
         native_data = spark.read.parquet(path+"native_result/",mode="overwrite")
         native_data.show()
         native_data_pd = native_data.toPandas()
-        native_data_pd.show()
+        native_data_pd.head()
 
         print("耗时(秒)：")
         print((time.time()-b))
\ No newline at end of file