TableAPI与SQL

概述

Flink 流式计算引擎中，提供Flink Table API & SQL模块，类似SparkSQL模块，从Flink1.12.0开始提供高层次API，以便用户用于统一流和批处理的上层API，开发程序更加简单。

Apache Flink 具有两个关系 API——Table API 和 SQL——用于统一的流和批处理。无论输入是连续（流式）还是有界（批处理），任一接口中指定的查询都具有相同的语义并指定相同的结果。

1. The Table API is a language-integrated query API for Java, Scala, and Python that allows the composition of queries from relational operators such as selection, filter, and join in a very intuitive way.

   Table API是Java、Scala和Python的语言集成查询API，类似SQL API，通过Table API，用户可以像操作表一样操作数据，非常直观和方便。

   ordersTab.groupBy($"a")
            .select($"a", $"b".count as "cnt")
            .execute()
            .print()
   

2. Flink’s SQL support is based on Apache Calcite which implements the SQL standard.

   Flink 的 SQL 支持基于实现了 SQL 标准的 Apache Calcite。

   SQL作为声明式语言，有标准的语法和规范，用户可以不关心底层实现，进行数据的处理，非常容易上手。

   xxxxxxxxxx
   SELECT dept_id,COUNT(*) as emp_count 
   FROM employee_information 
   GROUP BY dept_id;
   

总结Flink Table API & SQL优势:

1. 容易理解：语义明确，所见即所得。
2. 声明式：用户只需要关心做什么，不需要关心怎么做。
3. 流批统一：相同的程序既可以做流处理，也可以做批处理。
4. 高性能：支持查询优化，可以获得更高的执行性能。
5. 标准稳定：语言遵循SQL标准，不易变动。

实时效果反馈

1. 以下选项中关于Flink Table API & SQL描述正确的是？

A 流批统一：相同的程序既可以做流处理，也可以做批处理。

B 高性能：支持查询优化，可以获得更高的执行性能。

C 标准稳定：语言遵循SQL标准，不易变动。

D 以上三个选项都正确。

答案：

1=>D