Datepart

Extrahiert einen Teil der Datums-/Zeitstempel- oder Intervallquelle.

Syntax

from pyspark.databricks.sql import functions as dbf

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

Die Parameter

Parameter	Typ	Description
field	pyspark.sql.Column	wählt aus, welcher Teil der Quelle extrahiert werden soll, und unterstützte Zeichenfolgenwerte sind mit den Feldern der entsprechenden Funktion extractidentisch.
source	pyspark.sql.Column oder str	eine Datums-/Zeitstempel- oder Intervallspalte, aus der field extrahiert werden soll.

Rückkehr

pyspark.sql.Column: Ein Teil der Datums-/Zeitstempel- oder Intervallquelle.

Examples

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