常用语法

SET TIME ZONE LOCAL
SET TIME ZONE 'timezone_value'
SET TIME ZONE INTERVAL interval_literal

参数解释

• LOCAL

Set the time zone to the one specified in the java user.timezone property, or to the environment variable TZ if user.timezone is undefined, or to the system time zone if both of them are undefined.

• timezone_value

The ID of session local timezone in the format of either region-based zone IDs or zone offsets. Region IDs must have the form ‘area/city’, such as ‘America/Los_Angeles’. Zone offsets must be in the format ‘(+|-)HH’, ‘(+|-)HH:mm’ or ‘(+|-)HH:mm:ss’, e.g ‘-08’, ‘+01:00’ or ‘-13:33:33’. Also, ‘UTC’ and ‘Z’ are supported as aliases of ‘+00:00’. Other short names are not recommended to use because they can be ambiguous.

• interval_literal

The interval literal represents the difference between the session time zone to the ‘UTC’. It must be in the range of [-18, 18] hours and max to second precision, e.g. INTERVAL 2 HOURS 30 MINUTES or INTERVAL '15:40:32' HOUR TO SECOND.

示例

-- Set time zone to the system default.
SET TIME ZONE LOCAL;

-- Set time zone to the region-based zone ID.
SET TIME ZONE 'America/Los_Angeles';

-- Set time zone to the Zone offset.
SET TIME ZONE '+08:00';

-- Set time zone with intervals.
SET TIME ZONE INTERVAL 1 HOUR 30 MINUTES;
SET TIME ZONE INTERVAL '08:30:00' HOUR TO SECOND;

使用

如我们这里使用的是北京/重庆的时区，则可以用以下命令

SET TIME ZONE 'Asia/Shanghai'
SET TIME ZONE '+8:00';
SET TIME ZONE INTERVAL 8 HOUR;

spark.conf.set("spark.sql.session.timeZone", "Asia/Shanghai")

最后用下来发现只有如下语句可用

spark.sql("SET TIME ZONE 'Asia/Shanghai'")
spark.conf.set("spark.sql.session.timeZone", "Asia/Shanghai")