extract

Kinyeri a dátum/időbélyeg vagy intervallum forrásának egy részét.

A megfelelő Databricks SQL-függvényhez lásd a függvénytextract.

Szemantika

from pyspark.databricks.sql import functions as dbf

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

Paraméterek

Paraméter	Típus	Description
field	pyspark.sql.Column	kiválasztja a forrás melyik részét kell kinyerni.
source	pyspark.sql.Column vagy str	egy dátum/időbélyeg vagy intervallum oszlop, amelyből field ki kell nyerni.

Visszatérítések

pyspark.sql.Column: a dátum/időbélyeg vagy intervallum forrásának egy része.

Példák

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