date_trunc

Vrátí časové razítko zkrácené na jednotku určenou formátem.

Odpovídající funkci SQL Databricks vizte funkcedate_trunc.

Syntaxe

from pyspark.sql import functions as dbf

dbf.date_trunc(format=<format>, timestamp=<timestamp>)

Parametry

Parameter Typ Description
format literal string year, yyyyzkrátit yy podle roku, month, mon, , mm zkrátit podle měsíce, day, zkrátit dd podle dne, Další možnosti jsou: microsecond, millisecond, secondminute, hour, weekquarter
timestamp pyspark.sql.Column nebo str vstupní sloupec hodnot, který se má zkrátit.

Návraty

pyspark.sql.Column: zkrácené časové razítko.

Examples

from pyspark.sql import functions as dbf
df = spark.createDataFrame([('1997-02-28 05:02:11',)], ['ts'])
df.select('*', dbf.date_trunc('year', df.ts)).show()
df.select('*', dbf.date_trunc('mon', 'ts')).show()