Commit 6be48f32 authored by Your Name's avatar Your Name

dist predict test

parent fe9f631c
...@@ -258,11 +258,11 @@ if __name__ == "__main__": ...@@ -258,11 +258,11 @@ if __name__ == "__main__":
# #
# #
# # #nearby data # # #nearby data
# te_files = [] te_files = []
# for i in range(0,10): for i in range(0,10):
# te_files.append([path + "nearby/part-r-0000" + str(i)]) te_files.append([path + "nearby/part-r-0000" + str(i)])
# for i in range(10,100): for i in range(10,100):
# te_files.append([path + "nearby/part-r-000" + str(i)]) te_files.append([path + "nearby/part-r-000" + str(i)])
# #
# #
# rdd_te_files = spark.sparkContext.parallelize(te_files) # rdd_te_files = spark.sparkContext.parallelize(te_files)
......
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