Oharra
Baimena behar duzu orria atzitzeko. Direktorioetan saioa has dezakezu edo haiek alda ditzakezu.
Baimena behar duzu orria atzitzeko. Direktorioak alda ditzakezu.
Convierta la cadena de tiempo con un patrón dado ('aaaa-MM-dd HH:mm:ss', de forma predeterminada) a la marca de tiempo de Unix (en segundos), con la zona horaria predeterminada y la configuración regional predeterminada, devuelve null si se produjo un error. Si timestamp es None, devuelve la marca de tiempo actual.
Para obtener la función SQL de Databricks correspondiente, consulte unix_timestamp function.
Syntax
import pyspark.sql.functions as sf
# Returns current timestamp
sf.unix_timestamp()
# With timestamp
sf.unix_timestamp(timestamp=<timestamp>)
# With timestamp and format
sf.unix_timestamp(timestamp=<timestamp>, format=<format>)
Parámetros
| Parámetro | Tipo | Description |
|---|---|---|
timestamp |
pyspark.sql.Column o str |
Optional. Marcas de tiempo de valores de cadena. |
format |
str |
Optional. Formato alternativo que se usará para la conversión (valor predeterminado: aaaa-MM-dd HH:mm:ss). |
Devoluciones
pyspark.sql.Column: tiempo de unix como entero largo.
Examples
Ejemplo 1: devuelve la marca de tiempo actual en UNIX.
import pyspark.sql.functions as sf
spark.range(1).select(sf.unix_timestamp()).show()
+----------+
| unix_time|
+----------+
|1702018137|
+----------+
Ejemplo 2: El uso del formato predeterminado "aaaa-MM-dd HH:mm:ss" analiza la cadena de marca de tiempo.
import pyspark.sql.functions as sf
df = spark.createDataFrame([('2015-04-08 12:12:12',)], ['ts'])
df.select('*', sf.unix_timestamp('ts')).show()
+-------------------+---------------------------------------+
| ts|unix_timestamp(ts, yyyy-MM-dd HH:mm:ss)|
+-------------------+---------------------------------------+
|2015-04-08 12:12:12| 1428520332|
+-------------------+---------------------------------------+
Ejemplo 3: El uso del formato especificado por el usuario "aaaa-MM-dd" analiza la cadena de marca de tiempo.
import pyspark.sql.functions as sf
df = spark.createDataFrame([('2015-04-08',)], ['dt'])
df.select('*', sf.unix_timestamp('dt', 'yyyy-MM-dd')).show()
+----------+------------------------------+
| dt|unix_timestamp(dt, yyyy-MM-dd)|
+----------+------------------------------+
|2015-04-08| 1428476400|
+----------+------------------------------+