Flink 创建视图或 Table 为 Select

Question

我正在阅读 Flink SQL 文档，在有关创建的部分中，我找不到任何类似于 CREATE VIEW AS SELECT 或 CTAS 的内容。

我进一步查看，发现以下内容：

• Flink SQL 允许您 Select
• Flink SQL 允许您创建
• Flink SQL 允许您插入

因此，Flink SQL 似乎允许您模仿 Create as Select 的功能，但没有自动抓取源模式的便利 table .

此外，我发现：

• Flink（在 SQL 之外）允许您将 SQL Select 语句的输出分配给新的 table（可能是一个视图）

例如：

Table result = tableEnv.sqlQuery("SELECT product, amount FROM Orders WHERE product LIKE '%Rubber%'");

现在我的问题是：

（如何）Flink 是否允许您在不离开 SQL 上下文的情况下创建为 Select

根据我看到的示例，这可能可以改写为：

你能在 executeSql 语句中创建 as select 吗？

Answer 1

FlinkSQL中存在已知的CREATE VIEW AS SELECT since 1.11。在旧版本中，您需要求助于您指出的 table API。