Commit 2067e393 authored by 张彦钊's avatar 张彦钊

change test file

parent 08804d83
......@@ -147,10 +147,11 @@ if __name__ == '__main__':
# validate_date, value_map, app_list_map = feature()
# get_predict(validate_date, value_map, app_list_map)
import glob
spark = SparkSession.builder.getOrCreate()
d = spark.textFile("hdfs://172.16.32.4:8020/strategy/esmm/tr").collect()
print(d)
data_files = glob.glob("hdfs://172.16.32.4:8020/strategy/esmm/tr/")
print(data_files)
......
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