-
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等)。