楼主你好，在 Flink 的 Table API 中，是可以在表名后面使用子查询语句的，你可以看一下下面的例子：

SELECT * FROM (  SELECT a, b, c FROM table1 WHERE a > 100) WHERE b < 8

这样的语句是允许的，所以上在 TUMBLE 函数的第一个参数中也可以使用子查询语句，比如：

SELECT * FROM TUMBLE(  (    SELECT *    FROM table1 LEFT JOIN table2 ON table1.key = table2.key  ),  DESCRIPTOR(timecol),  size,  offset)

已喜欢 已反对