datepart

从日期/时间戳或时间间隔中提取部分内容。

Syntax

from pyspark.databricks.sql import functions as dbf

dbf.datepart(field=<field>, source=<source>)

参数

参数	类型	Description
field	pyspark.sql.Column	选择应提取的源部分，并且支持的字符串值与等效函数 extract的字段相同。
source	pyspark.sql.Column 或 str	从中提取日期 field /时间戳或间隔列。

退货

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.datepart(dbf.lit('YEAR'), 'ts').alias('year'),
dbf.datepart(dbf.lit('month'), 'ts').alias('month'),
dbf.datepart(dbf.lit('WEEK'), 'ts').alias('week'),
dbf.datepart(dbf.lit('D'), df.ts).alias('day'),
dbf.datepart(dbf.lit('M'), df.ts).alias('minute'),
dbf.datepart(dbf.lit('S'), df.ts).alias('second')
).show()