Re: FlinkSQL 是否支持类似临时中间表的概念

[Leonard Xu]

Hello，

你的需求其实是要 抽取记录的字段定义watermark， 这个只能放到source 表的DDL中，view上也不支持的。
1.10里的计算列 + udf 应该就可以满足你的需求, 大概长这样：

CREATE TABLE sourceTable (
 request_uri STRING,
 ts as extractTsUdf(request_uri),
 WATERMARK FOR ts AS ts - INTERVAL '5' SECOND

) WITH (
  ..........
);

select ... from (
select ts, T.* from 
sourceTable  sourceTable , LATERAL TABLE(ParseUriRow(request_uri)) as T(...)
) t
group by TUMBLE(ts, INTERVAL '30' SECOND)

祝好，
Leonard


> 在 2020年6月24日，12:09，Weixubin <18925434...@163.com> 写道：
> 
> 第一个数据处理过程就是将 request_uri 解析为多个属性（多列），存成一行，作为一条记录。