Flink创建视图或表为选择

问题描述

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

我进一步看了看,发现以下内容:

  • Flink SQL允许您选择
  • Flink SQL允许您创建
  • Flink SQL允许您插入

因此,似乎Flink SQL允许您模仿“按选择创建”功能,但没有自动获取源表模式的便利。

此外,我发现:

  • Flink(SQL外部)允许您将SQL Select语句的输出分配给新表(可能是视图)

例如:

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

现在我的问题:

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

根据我所看到的示例,可以将其改写为:

您可以在executeSql语句中创建as select吗?

解决方法

在Flink SQL中,存在已知的CREATE VIEW AS SELECT since 1.11。在旧版本中,您需要使用您指出的表API。

相关问答

依赖报错 idea导入项目后依赖报错,解决方案:https://blog....
错误1:代码生成器依赖和mybatis依赖冲突 启动项目时报错如下...
错误1:gradle项目控制台输出为乱码 # 解决方案:https://bl...
错误还原:在查询的过程中,传入的workType为0时,该条件不起...
报错如下,gcc版本太低 ^ server.c:5346:31: 错误:‘struct...