Commit 8fcbf8f5 authored by 张彦钊's avatar 张彦钊

修改测试文件

parent 6777ac2a
......@@ -186,6 +186,7 @@ def get_predict(date,value_map,app_list_map,level2_map,level3_map):
print("nearby")
nearby_pre.toPandas().to_csv(local_path+"nearby.csv", header=True)
spark.createDataFrame(rdd.filter(lambda x: x[6] == 1)
.map(lambda x: (x[0], x[1], x[2], x[7], x[8], x[9], x[10], x[11], x[12],
x[13], x[14], x[15],
......
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