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的新手，不知道为什么会出现问题。

相关内容

热门资讯

发现一款(WEPOke)外挂透... 发现一款(WEPOke)外挂透明挂辅助挂(透视)确实是真的有挂(2024已更新)(哔哩哔哩)；免费W...
每日必看推荐(德扑之星介绍)外... 每日必看推荐(德扑之星介绍)外挂透明挂辅助软件(透视)辅助透视(有挂教学)-哔哩哔哩；德扑之星介绍是...
我来教大家!fishpoker... 此外，数据分析德州(fishpoker)辅助神器app还具备辅助透视行为开挂功能，通过对客户fish...
推荐十款(aapoker规律)... 推荐十款(aapoker规律)外挂透明挂辅助软件(辅助挂)发牌机制(今日头条)-哔哩哔哩；wpk透视...
玩家科普(aapoker实测)... 玩家科普(aapoker实测)外挂透明挂辅助APP(辅助挂)确实真的有挂(2024已更新)(哔哩哔哩...
重大发现(线上wpk德州)外挂... 重大发现(线上wpk德州)外挂透明挂辅助器(透视)透视辅助(有挂方式)-哔哩哔哩准备好在线上wpk德...
盘点一款!poker worl... 盘点一款!poker world外挂(WepokE)外挂透明挂辅助app(辅助挂)曝光教程(有挂助手...
推荐一款(Wepoke规律)外... 推荐一款(Wepoke规律)外挂透明挂辅助工具(辅助挂)德州ai机器人(有挂方针)-哔哩哔哩；原来确...
2024教程(wepoke实锤... 2024教程(wepoke实锤)外挂透明挂辅助挂(辅助挂)果真真的有挂(2025已更新)(哔哩哔哩)...
重大通报(德州ai智能)外挂透... 重大通报(德州ai智能)外挂透明挂辅助插件(辅助挂)透视辅助(存在有挂)-哔哩哔哩;1分钟了解详细教...