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

change test file

parent 8444571b
...@@ -156,6 +156,12 @@ if __name__ == '__main__': ...@@ -156,6 +156,12 @@ if __name__ == '__main__':
s_output, s_err = proc.communicate() s_output, s_err = proc.communicate()
all_dart_dirs = s_output.split() all_dart_dirs = s_output.split()
print(all_dart_dirs) print(all_dart_dirs)
a = []
for i in all_dart_dirs:
print(i.split("/"))
if i.split("/")[3][:4] == "part":
print(i.split("/")[3])
# d = spark.textFile("hdfs://172.16.32.4:8020/strategy/esmm/tr").collect() # d = spark.textFile("hdfs://172.16.32.4:8020/strategy/esmm/tr").collect()
# print(d) # print(d)
......
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