Commit f5b458e8 authored by Your Name's avatar Your Name

dist test

parent cee6e52b
...@@ -285,7 +285,7 @@ if __name__ == "__main__": ...@@ -285,7 +285,7 @@ if __name__ == "__main__":
nearby_data.head() nearby_data.head()
native_data = spark.read.parquet(path+"native_result/",mode="overwrite") native_data = spark.read.parquet(path+"native_result/")
native_data.show() native_data.show()
native_data_pd = native_data.toPandas() native_data_pd = native_data.toPandas()
native_data_pd.head() native_data_pd.head()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment