ALTER STREAMING TABLE
适用于: Databricks SQL
允许你:
- 添加用于刷新现有流式处理表的计划。
- 更改流式处理表的现有刷新计划。
- 删除流式处理表的刷新计划。 如果删除了计划,则需要手动刷新对象以反映最新数据。
语法
ALTER STREAMING TABLE table_name
{
{ ADD | ALTER } SCHEDULE [ REFRESH ] schedule_clause |
DROP SCHEDULE
}
schedule_clause
{ EVERY number { HOUR | HOURS | DAY | DAYS | WEEK | WEEKS } |
CRON cron_string [ AT TIME ZONE timezone_id ] }
参数
-
要更改其定义的流式处理表的名称。 名称不得包含时态规范。
SCHEDULE [ REFRESH ] schedule_clause
允许向流式处理表添加计划或更改其计划。
EVERY number { HOUR | HOURS | DAY | DAYS | WEEK | WEEKS }
重要
此功能目前以公共预览版提供。
要安排定期进行的刷新,请使用
EVERY
语法。 如果指定了EVERY
语法,则会按照指定的间隔根据提供的值(如HOUR
、HOURS
、DAY
、DAYS
、WEEK
或WEEKS
)定期刷新流式处理表或具体化视图。 下表列出了number
可接受的整数值。Time unit 整数值 HOUR or HOURS
1 < = H < = 72 DAY or DAYS
1 < = D < = 31 WEEK or WEEKS
1 < = W < = 8 注意
包含的时间单位的单数形式和复数形式在语义上是等效的。
CRON cron_string [ AT TIME ZONE timezone_id ]
使用 qartz cron 值安排刷新。 接受有效 time_zone_values。 不支持
AT TIME ZONE LOCAL
。如果
AT TIME ZONE
不存在,则使用会话时区。 如果AT TIME ZONE
不存在并且未设置会话时区,则会引发错误。SCHEDULE
在语义上等效于SCHEDULE REFRESH
。
示例
-- Adds a schedule to refresh the streaming table once a day
-- at midnight in Los Angeles
> ALTER STREAMING TABLE my_st
ADD SCHEDULE CRON '0 0 0 * * ? *' AT TIME ZONE 'America/Los_Angeles';
-- Alters the schedule to run every 15 minutes for a streaming table
> ALTER STREAMING TABLE my_st
ALTER SCHEDULE CRON '0 0/15 * * * ? *';
-- Drops the schedule for a streaming table
> ALTER STREAMING TABLE my_st
DROP SCHEDULE;