我有一个函数可以写入按日期和时间划分的数据
df = df.withColumn("year", F.year(col(date_column))) \
.withColumn("month", F.month(col(date_column))) \
.withColumn("day", F.dayofmonth(col(date_column))) \
.withColumn("hour", F.hour(col(date_column)))
df.write.partitionBy("year","month","day","hour").mode("append").format("csv").save(destination)
输出被写入month=9
,我如何使它像month=09
一样,几个小时都是这样,例如hour=04
。
1条答案
按热度按时间bvpmtnay1#
你可以试试
和