分区转换函数：时间戳的转换，将数据分区为小时。 支持 Spark Connect。
警告
在 4.0.0 中弃用。 请改用 partitioning.hours。
Syntax
from pyspark.databricks.sql import functions as dbf
dbf.hours(col=<col>)
参数
| 参数 | 类型 | Description |
|---|---|---|
col |
pyspark.sql.Column 或 str |
要处理的目标日期或时间戳列。 |
退货
pyspark.sql.Column：按小时分区的数据。
例子
df.writeTo("catalog.db.table").partitionedBy(
hours("ts")
).createOrReplace()
注释
此函数只能与 partitionedBy DataFrameWriterV2 方法结合使用。