diff --git a/python/pyspark/sql/functions.py b/python/pyspark/sql/functions.py index b0498d029878..b5a7c18904b1 100644 --- a/python/pyspark/sql/functions.py +++ b/python/pyspark/sql/functions.py @@ -1433,8 +1433,12 @@ def timestamp_seconds(col): >>> from pyspark.sql.functions import timestamp_seconds >>> spark.conf.set("spark.sql.session.timeZone", "America/Los_Angeles") >>> time_df = spark.createDataFrame([(1230219000,)], ['unix_time']) - >>> time_df.select(timestamp_seconds(time_df.unix_time).alias('ts')).collect() - [Row(ts=datetime.datetime(2008, 12, 25, 7, 30))] + >>> time_df.select(timestamp_seconds(time_df.unix_time).alias('ts')).show() + +-------------------+ + | ts| + +-------------------+ + |2008-12-25 07:30:00| + +-------------------+ >>> spark.conf.unset("spark.sql.session.timeZone") """