日付切り捨て

フォーマットで指定された単位に切り捨てられたタイムスタンプを返します。

対応する Databricks SQL 関数については、 date_trunc関数を参照してください。

構文

Python

from pyspark.sql import functions as dbf

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

パラメーター

パラメーター	Type	説明
format	literal string	year、 yyyy 、 yyは年で切り捨て、 month 、 mon 、 mmは月で切り捨て、 day 、 dd日で切り捨て、その他のオプションは次のとおりです: microsecond 、 millisecond 、 second 、 minute 、 hour 、 week 、 quarter
timestamp	pyspark.sql.Column または str	切り捨てる値の入力列。

パラメーター	Type	説明
format	literal string	year、 yyyy 、 yyは年で切り捨て、 month 、 mon 、 mmは月で切り捨て、 day 、 dd日で切り捨て、その他のオプションは次のとおりです: microsecond 、 millisecond 、 second 、 minute 、 hour 、 week 、 quarter
timestamp	pyspark.sql.Column または str	切り捨てる値の入力列。

戻り値

pyspark.sql.Column: 切り捨てられたタイムスタンプ。

例

Python

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