必要に応じて指定した形式を使用して、列を TimestampType に変換します。 datetime パターンに従って形式を指定します。 既定では、形式が省略されている場合は、TimestampType への規則のキャストに従います。
col.cast("timestamp")に相当します。
対応する Databricks SQL 関数については、 to_timestamp 関数を参照してください。
構文
import pyspark.sql.functions as sf
sf.to_timestamp(col=<col>)
# With format
sf.to_timestamp(col=<col>, format=<format>)
パラメーター
| パラメーター | タイプ | Description |
|---|---|---|
col |
pyspark.sql.Column または str |
変換する列の値。 |
format |
str |
Optional. タイムスタンプ値の変換に使用する形式。 |
返品ポリシー
pyspark.sql.Column: pyspark.sql.types.TimestampType 型としてのタイムスタンプ値。
例示
例 1: 文字列をタイムスタンプに変換する。
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|
+-------------------+
例 2: 形式を使用して文字列をタイムスタンプに変換する。
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|
+------------------------------------+