日付切り捨て
フォーマットで指定された単位に切り捨てられたタイムスタンプを返します。
対応する Databricks SQL 関数については、 date_trunc関数を参照してください。
構文
Python
from pyspark.databricks.sql import functions as dbf
dbf.date_trunc(format=<format>, timestamp=<timestamp>)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
|
|
|
|
| 切り捨てる値の入力列。 |
戻り値
pyspark.sql.Column: 切り捨てられたタイムスタンプ。
例
Python
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()