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

change test file

parent b81b7ce6
......@@ -147,6 +147,7 @@ if __name__ == '__main__':
# validate_date, value_map, app_list_map = feature()
# get_predict(validate_date, value_map, app_list_map)
# [path + "tr/part-r-00000"]
import subprocess
dir_in = "/strategy/esmm/tr"
......@@ -156,16 +157,9 @@ if __name__ == '__main__':
s_output, s_err = proc.communicate()
all_dart_dirs = s_output.split()
print(all_dart_dirs)
a = []
for i in all_dart_dirs:
b = str(i).split("/")[4]
if b[:4] == "part":
a.append(b[:-1])
# print(str(i).split("/")[4][:-1])
print(a)
# d = spark.textFile("hdfs://172.16.32.4:8020/strategy/esmm/tr").collect()
# print(d)
print(type(all_dart_dirs))
......
This diff is collapsed.
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