(十三)Flink SQL
目录
DDL 操作
DML 操作
查询语句
1. SELECT DISTINCT
2. 窗口函数
3. 窗口聚合
4. OVER 聚合
5. 连接操作
6. TOP-N
Flink 对 SQL 的支持基于实现了 SQL 标准的 Apache Calcite,包括数据定义语言(Data Definition Language,DDL)、数据操纵语言(Data Manipulation Language,DML)以及查询语言。
目前 Flink SQL 所支持的所有语句如下:
- SELECT (Queries)
- CREATE TABLE, CATALOG, DATABASE, VIEW, FUNCTION
- DROP TABLE, DATABASE, VIEW, FUNCTION
- ALTER TABLE, DATABASE, FUNCTION
- ANALYZE TABLE
- INSERT
- UPDATE
- DELETE
- SQL HINTS
- DESCRIBE
- EXPLAIN
- USE
- SHOW
- LOAD
- UNLOAD
DDL 操作
DDL 主要指 CREATE、DROP、ALTER,这一类语句主要是用来操作元数据。简单使用方式如下:
import org.apache.flink.table.ap