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