날짜/타임스탬프 또는 간격 원본의 일부를 추출합니다.
문법
from pyspark.databricks.sql import functions as dbf
dbf.date_part(field=<field>, source=<source>)
매개 변수
| 매개 변수 | 유형 | Description |
|---|---|---|
field |
pyspark.sql.Column |
원본에서 추출할 부분을 선택하고 지원되는 문자열 값은 해당 함수 extract의 필드와 동일합니다. |
source |
pyspark.sql.Column 또는 str |
추출해야 하는 날짜 field /타임스탬프 또는 간격 열입니다. |
Returns
pyspark.sql.Column: 날짜/타임스탬프 또는 간격 원본의 일부입니다.
예시
import datetime
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(datetime.datetime(2015, 4, 8, 13, 8, 15),)], ['ts'])
df.select(
'*',
dbf.date_part(dbf.lit('YEAR'), 'ts').alias('year'),
dbf.date_part(dbf.lit('month'), 'ts').alias('month'),
dbf.date_part(dbf.lit('WEEK'), 'ts').alias('week'),
dbf.date_part(dbf.lit('D'), df.ts).alias('day'),
dbf.date_part(dbf.lit('M'), df.ts).alias('minute'),
dbf.date_part(dbf.lit('S'), df.ts).alias('second')
).show()