Commit 933ca33f authored by 张彦钊's avatar 张彦钊

change test file

parent 4408b21c
......@@ -92,7 +92,7 @@ def get_predict(date,value_map,app_list_map):
df = df.na.fill(dict(zip(features, features)))
rdd = df.select("level2_ids","ucity_id","device_id","cid_id","label", "y", "z") \
.rdd.map(lambda x: (app_list_func(x[0], app_list_map),x[1],x[2],x[3],x[4],float(x[5]),float(x[6]),
[value_map.get(x[1], 300000),value_map.get(date, 299999)]))
[value_map.get(x[1], 299999),value_map.get(date, 299998)]))
rdd.persist()
......
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