在flink sql-client中创建表
CREATE TABLE `paimon`.`db_paimon`.`test4` (
`id` INT NOT NULL,
`name` STRING,
dt TIMESTAMP(3),
CONSTRAINT `PK_id` PRIMARY KEY (`id`,dt) NOT ENFORCED
) PARTITIONED BY (dt)
WITH (
'snapshot.time-retained' = '100000d'
);
INSERT INTO test4 VALUES (1,'zs', CAST('2023-10-27 11:00:00' AS TIMESTAMP(3)));
INSERT INTO test4 VALUES (2,'zs2', CAST('2023-10-27 11:00:01' AS TIMESTAMP(3)));
INSERT INTO test4 VALUES (3,'zs3', CAST('2023-10-28 11:00:01' AS TIMESTAMP(3)));
在doris中创建异步物化视图
create materialized view test4_mv
BUILD IMMEDIATE
REFRESH AUTO ON SCHEDULE EVERY 1 minute
PROPERTIES
(
"replication_num" = "1"
)
as SELECT id,name,dt FROM paimon.db_paimon.test4
查询视图task
SELECT *
FROM tasks("type"="mv")
结果如下,显示还是全量刷新