Commit 839506da authored by 张彦钊's avatar 张彦钊

change test fliw

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