📅  最后修改于: 2022-03-11 14:45:05.660000             🧑  作者: Mango
DDLSchema = "user_id string, user_first_touch_timestamp long, email string"
usersDF = (spark.read
.option("sep", "\t")
.option("header", True)
.schema(DDLSchema)
.csv(usersCsvPath))