您可以使用 ALTER TABLE ... MODIFY QUERY 语句修改创建 materialized view 时指定的 SELECT 查询,而无需中断摄取过程。
此命令用于修改通过 TO [db.]name 子句创建的 materialized view。它不会更改底层存储表的结构,也不会更改 materialized view 的列定义,因此,对于未使用 TO [db.]name 子句创建的 materialized view,此命令的适用范围非常有限。
带 TO 表的示例
CREATE TABLE events (ts DateTime, event_type String)
ENGINE = MergeTree ORDER BY (event_type, ts);
CREATE TABLE events_by_day (ts DateTime, event_type String, events_cnt UInt64)
ENGINE = SummingMergeTree ORDER BY (event_type, ts);
CREATE MATERIALIZED VIEW mv TO events_by_day AS
SELECT toStartOfDay(ts) ts, event_type, count() events_cnt
FROM events
GROUP BY ts, event_type;
INSERT INTO events
SELECT DATE '2020-01-01' + interval number * 900 second,
['imp', 'click'][number%2+1]
FROM numbers(100);
SELECT ts, event_type, sum(events_cnt)
FROM events_by_day
GROUP BY ts, event_type
ORDER BY ts, event_type;
┌不带 TO 表的示例
该应用场景限制较多,因为你只能修改 SELECT 部分,无法添加新列。
CREATE TABLE src_table (`a` UInt32) ENGINE = MergeTree ORDER BY a;
CREATE MATERIALIZED VIEW mv (`a` UInt32) ENGINE = MergeTree ORDER BY a AS SELECT a FROM src_table;
INSERT INTO src_table (a) VALUES (1), (2);
SELECT * FROM mv;┌─a─┐
│ 1 │
│ 2 │
└───┘ALTER TABLE mv MODIFY QUERY SELECT a * 2 as a FROM src_table;
INSERT INTO src_table (a) VALUES (3), (4);
SELECT * FROM mv;┌─a─┐
│ 6 │
│ 8 │
└───┘
┌─a─┐
│ 1 │
│ 2 │
└───┘ALTER TABLE … MODIFY REFRESH 语句
ALTER TABLE ... MODIFY REFRESH 用于更改可刷新materialized view 的刷新参数,包括调度、依赖关系、随机化以及刷新设置。
ALTER TABLE [db.]name MODIFY REFRESH EVERY|AFTER ... [RANDOMIZE FOR ...] [DEPENDS ON ...] [SETTINGS ...]调度 (EVERY 或 AFTER) 是必需的:该语句会一次性替换所有刷新参数。任何未指定的子句——RANDOMIZE FOR、DEPENDS ON 或 SETTINGS——都会被移除或重置为默认值。若只想更改刷新设置,请重复当前调度。
该命令会就地更新现有视图的刷新配置,无需重新创建 materialized view 或其目标表,也不会清除现有目标数据或取消正在进行的刷新。更改配置期间,读取操作会继续针对现有目标表进行。
使用相同的完整 REFRESH 规范重复执行该命令是安全的。请务必重复应保留配置的每个子句,因为如上所述,每次执行都会替换所有刷新参数。
-- Change the schedule.
ALTER TABLE rmv MODIFY REFRESH EVERY 30 MINUTE;
-- Change retry settings (schedule must be repeated).
ALTER TABLE rmv MODIFY REFRESH EVERY 30 MINUTE
SETTINGS refresh_retries = 5,
refresh_retry_initial_backoff_ms = 500,
refresh_retry_max_backoff_ms = 60000;
-- Add or keep a dependency.
ALTER TABLE rmv MODIFY REFRESH EVERY 6 HOUR DEPENDS ON other_rmv;
-- Drop the dependency by omitting `DEPENDS ON`.
ALTER TABLE rmv MODIFY REFRESH EVERY 6 HOUR;限制:
- 不支持对 materialized view 执行
ALTER TABLE ... MODIFY SETTING;刷新设置只能通过MODIFY REFRESH修改。 - 不支持添加或移除
APPEND。 - 视图创建后,无法更改
all_replicas刷新设置。
完整的刷新设置列表见刷新设置。刷新状态 (包括当前生效的设置) 可在 system.view_refreshes 中查看。