Table API SQL的概念和通用API

目录

表API和SQL程序的结构

创建表环境（Create a TableEnvironment）

在目录中创建表（Create Tables in the Catalog）

临时表与永久表（Temporary vs Permanent tables）

遮蔽（Shadowing）

创建表（Create a Table）

连接器表（Connector Tables）

虚拟表（Virtual Tables）

表标识符（Table identifiers）

查询表（Query a Table）

Table API

SQL

混合表API和SQL（Mixing Table API and SQL）     

发出表（Emit a Table）

翻译并执行查询（Translate and Execute a Query） 

表的执行计划

---

        表API和SQL集成在一个联合API中。这个API的核心概念是一个表，它作为查询的输入和输出。本文展示了具有表API和SQL查询的程序的公共结构，如何注册表，如何查询表，以及如何发出表。

表API和SQL程序的结构

        下面的代码示例展示了表API和SQL程序的公共结构。

import org.apache.flink.table.api.*;
import org.apache.flink.connector.datagen.table.DataGenConnectorOptions;// Create a TableEnvironment for batch or streaming execution.
// See the "Create a TableEnvironment" section for details.
TableEnvironment tableEnv = TableEnvironment.create(/*…*/);// Create a source table
tableEnv.createTemporaryTable("SourceTable", TableDescriptor.forConnector("datagen").schema(Schema.newBuilder().column("f0", DataTypes.STRING()).build()).option(DataGenConnectorOptions.ROWS_PER_SECOND, 100L).bu