流处理表 (Streaming Table)
流处理表可以看成一种特殊的物化视图,可以用于流式数据的处理和查询。 流处理表除了可以动态获取源数据表的增量数据并将处理后的增量数据物化之外,它本身也支持通过在表名后"(stream)"后缀进行流式查询。
流处理表的创建同物化视图的创建类似,例如通过SQL可以创建流处理表:
CREATE STREAMING TABLE st1 AS
SELECT t1.a a1 FROM t1(stream) JOIN t2 ON t1.a = t2.b ;
使用 "(stream)" 后缀查询流处理表的增量数据 (上次查询之后新产生的数据):
SELECT * FROM st1(stream);
如果不使用"(stream)"后缀可以查询处理表的全量数据。
关于流处理表的创建和删除请参阅: