问题描述
我正在阅读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。