jubins commented on code in PR #56852:
URL: https://github.com/apache/spark/pull/56852#discussion_r3503142602
##########
python/pyspark/sql/functions/builtin.py:
##########
@@ -13179,6 +13179,55 @@ def timestamp_micros(col: "ColumnOrName") -> Column:
return _invoke_function_over_columns("timestamp_micros", col)
+@_try_remote_functions
+def timestamp_nanos(col: "ColumnOrName") -> Column:
+ """
+ Creates a nanosecond-precision timestamp (``TIMESTAMP_LTZ(9)``) from the
number of
+ nanoseconds since the UTC epoch.
+
+ .. versionadded:: 4.3.0
+
+ Parameters
+ ----------
+ col : :class:`~pyspark.sql.Column` or column name
+ a column of ``BIGINT`` or ``DECIMAL`` nanosecond values since the UTC
epoch.
+
+ Returns
+ -------
+ :class:`~pyspark.sql.Column`
+ a ``TIMESTAMP_LTZ(9)`` column representing the corresponding point in
time.
+
+ See Also
+ --------
+ :meth:`pyspark.sql.functions.timestamp_seconds`
+ :meth:`pyspark.sql.functions.timestamp_millis`
+ :meth:`pyspark.sql.functions.timestamp_micros`
+ :meth:`pyspark.sql.functions.unix_nanos`
+
+ Examples
+ --------
+ >>> import pyspark.sql.functions as sf
+ >>> spark.conf.set("spark.sql.timestampNanosTypes.enabled", "true")
Review Comment:
thanks for the review! added `spark.conf.set("spark.sql.session.timeZone",
"UTC")` before the nanos flag, and the matching
`spark.conf.unset("spark.sql.session.timeZone")` at the end of the doctest
block.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
