date_trunc

返回格式中指定的單位的截斷時間戳記。

關於對應的 Databricks SQL 函式,請參見 date_trunc 函數。

語法

from pyspark.sql import functions as dbf

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

參數

參數 類型 Description
format literal string year, , yyyy 以年份截斷, yy, month, mon 以月份截斷, mm, day 以日期截斷,其他選項有:dd, , microsecondmillisecondsecondminutehourweekquarter
timestamp pyspark.sql.Column 或 str 輸入欄位以截斷。

退貨

pyspark.sql.Column:截斷時間戳記。

範例

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