to_unix_タイムスタンプ
指定された時間の UNIX タイムスタンプを返します。
対応する Databricks SQL 関数については、 to_unix_timestamp関数を参照してください。
構文
Python
from pyspark.sql import functions as dbf
dbf.to_unix_timestamp(timestamp=<timestamp>, format=<format>)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
|
| 列または文字列を入力します。 |
|
| UNIX タイムスタンプ値を変換するために使用する形式。 |
例
Python
spark.conf.set("spark.sql.session.timeZone", "America/Los_Angeles")
Python
from pyspark.sql import functions as dbf
df = spark.createDataFrame([('2015-04-08 12:12:12',)], ['ts'])
df.select('*', dbf.to_unix_timestamp('ts')).show()
df = spark.createDataFrame([('2015-04-08',)], ['dt'])
df.select('*', dbf.to_unix_timestamp(df.dt, dbf.lit('yyyy-MM-dd'))).show()
df = spark.createDataFrame(
[('2015-04-08', 'yyyy-MM-dd'), ('2025+01+09', 'yyyy+MM+dd')], ['dt', 'fmt'])
df.select('*', dbf.to_unix_timestamp('dt', 'fmt')).show()
spark.conf.unset("spark.sql.session.timeZone")