（十）Flink Table API 和 SQL 基本概念
Apache Flink 有两种关系型 API 来做流批统一处理：Table API 和 SQL。Table API 是用于 Scala 和 Java 语言的查询 API，它可以用一种非常直观的方式来组合使用选取、过滤、join 等关系型算子。Flink SQL 是基于 Apache Calcite 来实现的标准 SQL。无论输入是连续的（流式）还是有界的（批处理），在两个接口中指定的查询都具有相同的语义，并指定相同的结果。
目录
基本概念
创建 TableEnvironment
在 Catalog 中创建表
查询表
输出表
基本概念
Table API 和 SQL 集成在同一套 API 中。这套 API 的核心概念是 Table，用作查询的输入和输出。下面我们将介绍 Table API 和 SQL 查询程序的通用结构、如何注册 Table、如何查询 Table 以及如何输出 Table。
下面的代码示例展示了 Table API 和 SQL 程序的通用结构。
import org.apache.flink.connector.datagen.table.DataGenConnectorOptions;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.*;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;public class TableApiExample {public static void main(String[] args) {// 为指定的流或者批计划器创建一个 TableEnvironment.