pyspark.sql.functions.timestamp_millis#

pyspark.sql.functions.timestamp_millis(col)[source]#

Creates timestamp from the number of milliseconds since UTC epoch.

New in version 3.5.0.

Parameters

colColumn or column name

unix time values.

Returns

Column

converted timestamp value.

See also

pyspark.sql.functions.timestamp_seconds()

pyspark.sql.functions.timestamp_micros()

pyspark.sql.functions.unix_millis()

Examples

>>> spark.conf.set("spark.sql.session.timeZone", "UTC")

>>> import pyspark.sql.functions as sf
>>> df = spark.createDataFrame([(1230219000,), (1280219000,)], ['millis'])
>>> df.select('*', sf.timestamp_millis('millis')).show()
+----------+------------------------+
|    millis|timestamp_millis(millis)|
+----------+------------------------+
|1230219000|     1970-01-15 05:43:39|
|1280219000|     1970-01-15 19:36:59|
+----------+------------------------+

>>> spark.conf.unset("spark.sql.session.timeZone")