Compartir a través de

to_unix_timestamp

返回给定时间的 UNIX 时间戳。

有关相应的 Databricks SQL 函数，请参阅 to_unix_timestamp 函数。

Syntax

from pyspark.databricks.sql import functions as dbf

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

参数

参数 类型 Description
timestamp pyspark.sql.Column 或 str 输入列或字符串。
format pyspark.sql.Column 或 str, optional 用于转换 UNIX 时间戳值的格式。

例子

spark.conf.set("spark.sql.session.timeZone", "America/Los_Angeles")

from pyspark.databricks.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")
  • Last updated on