次の方法で共有


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 yearyyyy、年単位で切り捨てる yymonthmon、月単位で切り捨てる mmday、日単位で切り捨てる dd 、その他のオプションは、 microsecondmillisecondsecondminutehourweekquarter
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()