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