date_trunc

Возвращает метку времени, усеченную в единицу, указанную в формате.

Для соответствующей функции Databricks SQL смотрите функцию date_trunc.

Синтаксис

from pyspark.databricks.sql import functions as dbf

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

Параметры

Параметр	Тип	Description
format	literal string	year, yyyyдля усечения по годам, monthmonmm , для усечения по месяцам, для усечения по дням, dddayдругие варианты: microsecond, millisecondhoursecondminuteweekyyquarter
timestamp	pyspark.sql.Column или str	входной столбец значений для усечения.

Возвраты

pyspark.sql.Column: усеченная метка времени.

Примеры

from pyspark.databricks.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()