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 SECOND
sql语法格式:
select INTERVAL '22:00:00' HOUR TO SECOND
【讨论】:
您好,谢谢,但我需要投射它,请问我知道如何投射到 timstamp 吗?以上是关于pyspark中的间隔类型的主要内容,如果未能解决你的问题,请参考以下文章
如何在 PySpark 中跨多个时间间隔使用 .filter() 操作?