flink 1.14版本 怎么用 create table as select

在 Flink 1.14 版本中，可以使用以下语句创建新表并将查询结果插入其中：

CREATE TABLE new_table_name
WITH (
  'connector' = 'filesystem',
  'path' = '/path/to/new_table_name',
  'format' = 'csv'
)
AS
SELECT * FROM source_table_name;

其中，new_table_name 表示新表的名称，/path/to/new_table_name 表示新表在文件系统中的路径，csv 表示新表的数据格式，可以根据具体需要调整。通过 WITH 子句指定表的连接器、路径和格式等属性，AS 子句后面的 SELECT 语句用于指定要插入到新表中的数据。

除了 * 外，还可以指定要查询的特定列，例如：

CREATE TABLE new_table_name
WITH (
  'connector' = 'filesystem',
  'path' = '/path/to/new_table_name',
  'format' = 'csv'
)
AS
SELECT col1, col2 FROM source_table_name;

该语句会创建一个新表 new_table_name，并将 source_table_name 中的 col1 和 col2 列插入到新表中。注意，在使用 CREATE TABLE AS SELECT 语句时，新表的连接器、路径和格式等属性都需要指定。