用于将数据中的时间戳和日期划分为年份的转换。
注释
此函数只能与方法结合使用 DataFrameWriterV2.partitionedBy 。
Syntax
from pyspark.sql.functions import partitioning
partitioning.years(col)
参数
| 参数 | 类型 | Description |
|---|---|---|
col |
pyspark.sql.Column 或 str |
要处理的目标日期或时间戳列。 |
例子
from pyspark.sql.functions import partitioning
df.writeTo("catalog.db.table").partitionedBy(
partitioning.years("ts")
).createOrReplace()