SparkSQL如何将字符串格式时间提前半小时并保留原格式？

直接用DATEADD返回null是因为它无法识别12小时制的字符串格式，必须先把字符串转成Spark能处理的时间戳类型，调整后再转回原格式。

完整查询语句 #

假设你的表名为your_table，存储12小时制时间的列是time_str，执行以下SQL即可生成目标列：

SELECT
  time_str,
  date_format(
    to_timestamp(time_str, 'hh:mm a') - INTERVAL 30 MINUTES,
    'hh:mm a'
  ) AS new_time
FROM your_table;

分步说明 #

1. 转换为时间戳类型：to_timestamp(time_str, 'hh:mm a')将12小时制字符串转为Spark可处理的时间戳，其中hh对应12小时制小时数，a匹配AM/PM标记。
2. 减去半小时：用- INTERVAL 30 MINUTES直接对时间戳做减法，语法直观且能自动处理跨天场景（比如12:00 AM减30分钟会得到11:30 PM）。
3. 转回12小时制字符串：date_format(..., 'hh:mm a')把调整后的时间戳重新格式化为和原列一致的12小时制字符串。

单值测试示例 #

如果要验证单个时间的处理结果，执行：

SELECT date_format(to_timestamp('06:00 AM', 'hh:mm a') - INTERVAL 30 MINUTES, 'hh:mm a') AS new_time;

会返回预期结果05:30 AM。

内容的提问来源于stack exchange，提问作者Ian