to_timestamp

Konwertuje kolumnę na timestampType przy użyciu opcjonalnego formatu. Określ formaty zgodnie ze wzorcem daty/godziny. Domyślnie jest to zgodne z regułami rzutowania do właściwości TimestampType, jeśli format zostanie pominięty. Odpowiednik col.cast("timestamp").

Aby uzyskać odpowiednią funkcję SQL usługi Databricks, zobacz to_timestamp funkcja.

Składnia

import pyspark.sql.functions as sf

sf.to_timestamp(col=<col>)

# With format
sf.to_timestamp(col=<col>, format=<format>)

Parametry

Parameter	Typ	Description
col	pyspark.sql.Column lub str	Wartości kolumn do konwersji.
format	str	Opcjonalny. Formatuj w celu przekonwertowania wartości znacznika czasu.

Zwraca

pyspark.sql.Column: wartość znacznika czasu jako pyspark.sql.types.TimestampType typ.

Przykłady

Przykład 1. Konwertowanie ciągu na znacznik czasu.

import pyspark.sql.functions as sf
df = spark.createDataFrame([('1997-02-28 10:30:00',)], ['t'])
df.select(sf.to_timestamp(df.t)).show()

+-------------------+
|    to_timestamp(t)|
+-------------------+
|1997-02-28 10:30:00|
+-------------------+

Przykład 2. Konwertowanie ciągu na znacznik czasu przy użyciu formatu.

import pyspark.sql.functions as sf
df = spark.createDataFrame([('1997-02-28 10:30:00',)], ['t'])
df.select(sf.to_timestamp(df.t, 'yyyy-MM-dd HH:mm:ss')).show()

+------------------------------------+
|to_timestamp(t, yyyy-MM-dd HH:mm:ss)|
+------------------------------------+
|                 1997-02-28 10:30:00|
+------------------------------------+