pyspark中的间隔类型

Posted

技术标签:

【中文标题】pyspark中的间隔类型【英文标题】:Interval type in pyspark 【发布时间】:2022-01-02 16:46:42 【问题描述】:
spark.sql("""SELECT CAST('22:00:00' AS INTERVAL HOUR TO SECOND)""").show()

我正在执行上述查询,但出现以下错误

ERROR : ParseException: 
missing ')' at 'HOUR'(line 1, pos 35)

【问题讨论】:

【参考方案1】:

INTERVAL HOUR TO SECONDsql语法格式:

select INTERVAL '22:00:00' HOUR TO SECOND

【讨论】:

您好,谢谢,但我需要投射它,请问我知道如何投射到 timstamp 吗?

以上是关于pyspark中的间隔类型的主要内容,如果未能解决你的问题,请参考以下文章

为pyspark数据框中的记录间隔分配一个常数值

RDD的Pyspark平均间隔

如何在pyspark中设置计数id的日期间隔?

如何在 PySpark 中跨多个时间间隔使用 .filter() 操作?

读取 pyspark 数据框中的 jsonb 类型字段? [复制]

Pyspark:检查数组类型列是不是包含列表中的值[重复]