date_part

Extrait une partie de la date/du Timestamp ou de la source d'intervalle.

Syntaxe

Python

from pyspark.sql import functions as dbf

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

parameter

parameter	Type	Description
field	pyspark.sql.Column	Sélectionne la partie de la source à extraire, et les valeurs de chaîne prises en charge sont les mêmes que les champs de la fonction équivalente extract.
source	pyspark.sql.Column OU str	Une colonne de date/timestamp ou d'intervalle d'où field doit être extrait.

parameter	Type	Description
field	pyspark.sql.Column	Sélectionne la partie de la source à extraire, et les valeurs de chaîne prises en charge sont les mêmes que les champs de la fonction équivalente extract.
source	pyspark.sql.Column OU str	Une colonne de date/timestamp ou d'intervalle d'où field doit être extrait.

Renvoie

pyspark.sql.Column: une partie de la source de date/Timestamp ou d'intervalle.

Exemples

Python

import datetime
from pyspark.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()