Datepart

Extraheert een deel van de datum/tijdstempel of intervalbron.

Syntaxis

from pyspark.databricks.sql import functions as dbf

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

Parameterwaarden

Kenmerk	Typologie	Description
field	pyspark.sql.Column	selecteert welk deel van de bron moet worden geëxtraheerd en ondersteunde tekenreekswaarden zijn hetzelfde als de velden van de equivalente functie extract.
source	pyspark.sql.Column of str	een datum-/tijdstempel- of intervalkolom van waaruit field moet worden geëxtraheerd.

Retouren

pyspark.sql.Column: een deel van de datum/tijdstempel of intervalbron.

Voorbeelden

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()