Nota
O acesso a esta página requer autorização. Podes tentar iniciar sessão ou mudar de diretório.
O acesso a esta página requer autorização. Podes tentar mudar de diretório.
Extrai uma parte da data/timestamp ou do intervalo de origem.
Sintaxe
from pyspark.databricks.sql import functions as dbf
dbf.datepart(field=<field>, source=<source>)
Parâmetros
| Parâmetro | Tipo | Description |
|---|---|---|
field |
pyspark.sql.Column |
seleciona qual parte da fonte deve ser extraída, e os valores das cadeias suportadas são iguais aos campos da função extractequivalente . |
source |
pyspark.sql.Column ou str |
uma data/hora ou uma coluna de intervalo de onde field deve ser extraído. |
Devoluções
pyspark.sql.Column: uma parte da data/hora ou da fonte do 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.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()