Nota:
El acceso a esta página requiere autorización. Puede intentar iniciar sesión o cambiar directorios.
El acceso a esta página requiere autorización. Puede intentar cambiar los directorios.
用于将时间戳和日期的数据分区为按月份的转换。
注释
此函数只能与方法结合使用 DataFrameWriterV2.partitionedBy 。
Syntax
from pyspark.sql.functions import partitioning
partitioning.months(col)
参数
| 参数 | 类型 | Description |
|---|---|---|
col |
pyspark.sql.Column 或 str |
要处理的目标日期或时间戳列。 |
例子
from pyspark.sql.functions import partitioning
df.writeTo("catalog.db.table").partitionedBy(
partitioning.months("ts")
).createOrReplace()