【发布时间】:2021-11-30 17:51:43
【问题描述】:
spark.sql("select CASE WHEN ((from_unixtime(unix_timestamp(dt,'yyyyMMdd'),'yyyyMMdd') == dt) or (from_unixtime(unix_timestamp(dt,'MMddyyyy'),'MMddyyyy') == dt)) then dt else '' end as dt, case WHEN ((from_unixtime(unix_timestamp(dt,'yyyyMMdd'),'yyyyMMdd') == dt) or (from_unixtime(unix_timestamp(dt,'MMddyyyy'),'MMddyyyy') == dt)) then 'Y' else 'dt: should be present in \"yyyyMMdd\" or \"MMddyyyy\" format' end as dt_flag from input").show(false)
在上面的代码中,我编写了接受两种格式的查询 yyyyMMdd 和 MMddyyyy
在这种情况下,应该接受多个分隔符,例如没有分隔符、句点、逗号、斜杠、破折号 日期类型。
我不知道如何添加这些,请帮助我!提前致谢
【问题讨论】:
标签: sql dataframe apache-spark apache-spark-sql