try_to_time

Convierte una columna en TimeType con el formato especificado opcionalmente. Especifique formatos según el patrón datetime. De forma predeterminada, sigue las reglas de conversión a TimeType si se omite el formato. Equivalente a col.cast("time"). La función siempre devuelve null en una entrada no válida.

Syntax

import pyspark.sql.functions as sf

sf.try_to_time(str=<str>)

# With format
sf.try_to_time(str=<str>, format=<format>)

Parámetros

Devoluciones

pyspark.sql.Column: valor de hora como pyspark.sql.types.TimeType tipo.

Examples

Ejemplo 1: Convertir cadena en una hora.

import pyspark.sql.functions as sf
df = spark.createDataFrame([("10:30:00",)], ["str"])
df.select(sf.try_to_time(df.str).alias("time")).show()

+--------+
|    time|
+--------+
|10:30:00|
+--------+

Ejemplo 2: Convertir cadena a una hora con un formato.

import pyspark.sql.functions as sf
df = spark.createDataFrame([("10:30:00", "HH:mm:ss")], ["str", "format"])
df.select(sf.try_to_time(df.str, df.format).alias("time")).show()

+--------+
|    time|
+--------+
|10:30:00|
+--------+

Ejemplo 3: El error de conversión da como resultado NULL.

import pyspark.sql.functions as sf
df = spark.createDataFrame([("malformed",)], ["str"])
df.select(sf.try_to_time(df.str).alias("time")).show()

+----+
|time|
+----+
|NULL|
+----+