Flink SQL 多个表

Flink SQL 支持多个表的查询和操作，常见的方式有两种：

1. 使用 JOIN 操作符将多个表连接起来，可以使用 INNER JOIN、LEFT JOIN、RIGHT JOIN 等不同的 JOIN 类型。例如：

SELECT t1.column1, t2.column2
FROM table1 AS t1
JOIN table2 AS t2
ON t1.key = t2.key;

2. 使用 UNION 操作符将多个表的数据合并起来，要求多个表的列数和数据类型必须一致。例如：

SELECT column1, column2
FROM table1
UNION ALL
SELECT column1, column2
FROM table2;

在 Flink SQL 中，可以通过在 CREATE TABLE 语句中指定表的 schema，来定义表的列名和数据类型。例如：

CREATE TABLE table1 (
  column1 INT,
  column2 STRING
) WITH (
  'connector.type' = 'csv',
  'connector.path' = 'path/to/table1.csv'
);

CREATE TABLE table2 (
  column1 INT,
  column2 STRING
) WITH (
  'connector.type' = 'csv',
  'connector.path' = 'path/to/table2.csv'
);

然后就可以在 SQL 查询中引用这些表了。