形式で指定した単位に切り捨てたタイムスタンプを返します。
対応する 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 、その他のオプションは、 microsecond、 millisecond、 second、 minute、 hour、 week、 quarter |
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()