pyspark.sql.functions。
小時
分區轉換功能:時間戳數據分割成小時的變換。
筆記
這個函數隻能結合使用partitionedBy ()的方法DataFrameWriterV2。
partitionedBy ()
例子
> > >df。用writeTo(“catalog.db.table”)。partitionedBy(…小時(“t”)…)。createOrReplace()
以前的
pyspark.sql.functions.days
下一個
pyspark.sql.functions.bucket