Flink SQL 是 Apache Flink 项目中的一个重要组成部分，它允许开发者使用标准的 SQL 语言来处理流数据和批处理数据。Flink SQL 提供了一种声明式的编程范式，使得用户能够以一种简洁、高效且易于理解的方式来表达复杂的数据处理逻辑。

### 背景

Flink SQL 的设计初衷是为了简化实时计算模型，降低用户使用实时计算的门槛【1】。随着数据流处理需求的日益增长，传统的编程模型（如使用 Datastream API）虽然灵活，但存在一定的使用门槛，且难以优化和调试【1】。因此，Flink SQL 作为一种更接近传统数据库查询语言的接口，应运而生，它使得开发者可以更加专注于业务逻辑，而无需深入底层的数据处理细节。

### 核心特性

- **流批一体**：Flink SQL 支持流处理和批处理的统一，这意味着同一套 SQL 语句可以同时处理实时数据流和静态数据集【2】【3】。
- **易于理解和使用**：Flink SQL 遵循 ANSI SQL 标准，使得有 SQL 背景的开发者能够快速上手【1】【2】。
- **自动优化**：Flink SQL 内置了查询优化器，能够自动为 SQL 语句生成最优的执行计划【1】。
- **丰富的算子和函数**：Flink SQL 提供了丰富的算子（如 select、join、group by 等）和内置函数，支持复杂的数据处理和分析任务【5】。

### 编程模型

Flink SQL 的编程模型包括三个主要部分：Source Operator、Query Operators 和 Sink Operator【5】。

- **Source Operator**：用于抽象外部数据源，如 Kafka、文件系统等【5】。