try_to_timestamp

Parsuje col časové format razítko s časovým razítkem. Funkce vždy vrátí hodnotu null pro neplatný vstup s povoleným režimem ANSI SQL nebo bez. Datový typ výsledku je konzistentní s hodnotou konfigurace spark.sql.timestampType.

Odpovídající funkci SQL Databricks vizte funkcetry_to_timestamp.

Syntaxe

from pyspark.sql import functions as dbf

dbf.try_to_timestamp(col=<col>, format=<format>)

Parametry

Parameter	Typ	Description
col	pyspark.sql.Column nebo str	hodnoty sloupce, které chcete převést.
format	literal string, optional	formát, který se použije k převodu hodnot časového razítka.

Examples

from pyspark.sql import functions as dbf
df = spark.createDataFrame([('1997-02-28 10:30:00',)], ['t'])
df.select(dbf.try_to_timestamp(df.t)).show()
df = spark.createDataFrame([('1997-02-28 10:30:00',)], ['t'])
df.select(dbf.try_to_timestamp(df.t, dbf.lit('yyyy-MM-dd HH:mm:ss'))).show()
origin = spark.conf.get("spark.sql.ansi.enabled")
spark.conf.set("spark.sql.ansi.enabled", "true")
try:
df = spark.createDataFrame([('malformed',)], ['t'])
df.select(dbf.try_to_timestamp(df.t)).show()
finally:
spark.conf.set("spark.sql.ansi.enabled", origin)