Commit 49174db0 authored by 张彦钊's avatar 张彦钊

change test fliw

parent 02f7ca6a
......@@ -236,7 +236,7 @@ if __name__ == '__main__':
# TODO 删除下面的测试写入
df = spark.sql("select y,z from esmm_train_data limit 6000")
df.write.format("tfrecords").option("recordType", "Example").save(path="hdfs:///strategy/esmm/tr/")
df.write.format("tfrecords").option("recordType", "Example").save(path="hdfs:///strategy/esmm/tr",mode="overwrite")
print("done")
......
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