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

修改测试文件

parent dee160a5
...@@ -109,9 +109,9 @@ def feature_engineer(): ...@@ -109,9 +109,9 @@ def feature_engineer():
print("test.count",test.count()) print("test.count",test.count())
print("train count",train.count()) print("train count",train.count())
# spark.createDataFrame(test).write.csv('/recommend/va', mode='overwrite', header=True) spark.createDataFrame(test).write.csv('/recommend/va', mode='overwrite', header=True)
# spark.createDataFrame(train).write.csv('/recommend/tr', mode='overwrite', header=True) spark.createDataFrame(train).write.csv('/recommend/tr', mode='overwrite', header=True)
# print("done") print("done")
return validate_date,value_map,app_list_map,leve2_map,leve3_map return validate_date,value_map,app_list_map,leve2_map,leve3_map
......
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