Compartir vía


extract

Extrae una parte del origen de fecha/hora o intervalo.

Para obtener la función SQL de Databricks correspondiente, consulte extract function.

Syntax

from pyspark.databricks.sql import functions as dbf

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

Parámetros

Parámetro Tipo Description
field pyspark.sql.Column selecciona qué parte del origen se debe extraer.
source pyspark.sql.Column o str una columna date/timestamp o interval de donde field se debe extraer.

Devoluciones

pyspark.sql.Column: parte del origen de fecha/hora o intervalo.

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