dist test

eda/esmm/Model_pipline/dist_predict.py

@@ -286,6 +286,7 @@ if __name__ == "__main__":
         nearby_data = te_result_dataframe.toPandas()
         print("nearby pd data")
         print(nearby_data.head())
+        print(nearby_data.dtypes)
 
 
         native_data = spark.read.parquet(path+"native_result/")
@@ -294,6 +295,7 @@ if __name__ == "__main__":
         native_data_pd = native_data.toPandas()
         print("native pd data")
         print(native_data_pd.head())
+        print(native_data_pd.dtypes)
 
         print("耗时(秒)：")
         print((time.time()-b))