파티션 변환 함수: 타임스탬프 및 날짜를 월로 분할하는 변환입니다. Spark Connect를 지원합니다.
경고
4.0.0에서 사용되지 않습니다.
partitioning.months를 대신 사용하세요.
문법
from pyspark.databricks.sql import functions as dbf
dbf.months(col=<col>)
매개 변수
| 매개 변수 | 유형 | Description |
|---|---|---|
col |
pyspark.sql.Column 또는 str |
작업할 대상 날짜 또는 타임스탬프 열입니다. |
Returns
pyspark.sql.Column: 월별로 분할된 데이터입니다.
예시
df.writeTo("catalog.db.table").partitionedBy(
months("ts")
).createOrReplace()
비고
이 함수는 DataFrameWriterV2의 메서드와 partitionedBy 함께 사용할 수 있습니다.