ApacheSpark中的to_timestamp()函数在Databricks上无法与PySpark一起使用
创始人
2024-09-06 12:30:20
0次

在Databricks中，to_timestamp()函数无法在PySpark中将字符串转换为时间戳。解决方案是使用to_utc_timestamp()函数并将时区设置为GMT。

示例代码：

from pyspark.sql.functions import to_utc_timestamp
from pyspark.sql.functions import from_unixtime

df = spark.createDataFrame([('2020-01-01T12:00:00.000Z',)], ['timestamp_str'])
df1 = df.withColumn('timestamp_utc', to_utc_timestamp(df.timestamp_str, 'GMT'))
df2 = df1.withColumn('timestamp', from_unixtime(df1.timestamp_utc.cast('long')))
df2.show()

上一篇：ApacheSpark中的requiredChildDistribution和outputPartitioning有什么区别？

下一篇：ApacheSpark中关于SparkAccumulatorV2的问题。我是一个Spark的新手，不知道为什么会出现问题。

相关内容

热门资讯

后台5分钟!wepoke真的w... 后台5分钟!wepoke真的wpk ai检测(的确是有挂的)-微博客户端；亲，关键说明，wpk ai...
安装三分钟!微扑克私人局后台操... 安装三分钟!微扑克私人局后台操控扑克时间辅助软件(本来真的有挂)-知乎；微扑克私人局后台操控辅助器中...
稳赢三分钟!德扑之星电脑版we... 稳赢三分钟!德扑之星电脑版wepoke软件下载(其实真的有挂)-今日头条1、不需要AI权限，帮助你快...
德州3分钟!微扑克代打是真的a... 德州3分钟!微扑克代打是真的aapoker透明挂(果然真的有挂)-今日头条1、完成微扑克代打是真的的...
苹果版十分钟!wpk提高胜率w... 苹果版十分钟!wpk提高胜率wpk微扑克俱乐部(果真真的有挂)-微博客户端wpk微扑克俱乐部软件透明...
输赢2分钟!微扑克辅助挂德州之... 输赢2分钟!微扑克辅助挂德州之星辅助可以用(一般真的有挂)-微博客户端1.德州之星辅助可以用 ai辅...
代打两分钟!pokermast... 代打两分钟!pokermaster外挂微扑克伙牌技巧(果然真的有挂)-微博客户端1、进入游戏-大厅左...
规律七分钟!来玩德州有外挂德扑... 您好，德扑线上有机器人这款游戏可以开挂的，确实是有挂的，需要了解加微【487309276】很多玩家在...
开挂9分钟!wpk辅助器安装德... 开挂9分钟!wpk辅助器安装德扑数据软件(其实真的有挂)-微博客户端；1、构建自己的德扑数据软件辅助...
app十分钟!we-poke有... app十分钟!we-poke有挂wpk透视辅助器(一贯真的有挂)-知乎1、在wpk透视辅助器ai机器...