Commit 12388704 authored by 张彦钊's avatar 张彦钊

修改测试文件

parent 84b17846
......@@ -174,7 +174,7 @@ def get_predict(date,value_map,app_list_map,level2_map,level3_map):
spark.createDataFrame(rdd.filter(lambda x: x[6] == 1)
.map(lambda x: (x[0], x[1], x[2], x[9], x[10], x[11], x[12], x[13], x[14], x[15],
x[16, x[17], x[18], x[19], x[20], x[21], x[22], x[23]]))) \
x[16], x[17], x[18], x[19], x[20], x[21], x[22], x[23]))) \
.toDF("app_list", "level2_ids", "level3_ids", "ucity_id",
"ccity_name", "device_type", "manufacturer", "channel", "time", "hospital_id",
"treatment_method", "price_min", "price_max", "treatment_time", "maintain_time",
......
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