- **flink-core.jar：**
包含了Flink的核心代码，例如JobGraph、TaskManager、Task、Checkpoint等。这些类是Flink运行时环境的核心组件，负责实现作业的调度、执行和容错等功能。

- **flink-java.jar：**
包含了Flink的Java API，例如DataStream、DataSet、ExecutionEnvironment等。这些类是Flink编程的核心组件，提供了基于数据流和数据集的API，方便用户编写分布式数据处理程序。

- **flink-streaming-java.jar：**
包含了Flink的流处理API，例如DataStream、Window、Time等。这些类是Flink流处理的核心组件，提供了基于事件时间和处理时间的流处理API，支持窗口、状态管理、水印等特性。

- **flink-table-blink.jar：**
包含了Flink的Blink表格API，例如Table、TableEnvironment等。这些类是Flink表格API的核心组件，提供了基于SQL的表格查询和流处理功能，方便用户编写复杂的数据处理任务。

- **flink-metrics-core.jar：**
包含了Flink的度量API，例如Counter、Gauge、Histogram等。这些类是Flink度量系统的核心组件，提供了丰富的度量指标和可视化功能，方便用户监控和调试Flink应用程序。

- ** flink-connector-*：**
包含了Flink的各种数据源和数据接收器的连接器，例如flink-connector-kafka、flink-connector-hdfs等。这些类是Flink与各种数据存储和消息队列的连接器，方便用户在Flink中读写数据。

- **flink-shaded-hadoop-*：**
包含了Flink对Hadoop依赖库进行了一定程度的封装和优化后的JAR包。这些类是Flink在使用Hadoop相关功能时所需要的库文件。

- **flink-dist_2.11-1.14.2.jar：**
Flink 本身包含运行所需的一组类和依赖，比如协调、网络通讯、checkpoint、容错处理、API、算子(如窗口操作)、 资源管理等，这些类和依赖形成了 Flink 运行时的核心。当 Flink 应用启动时，这些依赖必须可用。这些依赖类似 Java String 和 List 的核心类库(rt.jar, charsets.jar等)。

ITPub博客

Flink发行包中 lib 目录下的文件作用

最新文章