在我们要开发Flink程序时,就会涉及到应该加载哪些Flink jar的问题。本章内容就是向你展示如何配置你的项目,添加必要的依赖。
每个应用程序都会依赖一些 Flink libraries,比如至少依赖 Flink APIs库,如果使用了connector,则还需要依赖connector相关的库,比如kafka、jdbc等,和你自己程序需要的第三方库。
Flink APIs
Flink主要提供了两种主要APIs:Datastream API and Table API & SQL.。可以同时使用或分开使用。下面是你要用的APIs,以及你应该添加的依赖:
你要使用的APIs | 需要添加的依赖 |
DataStream | flink-streaming-java |
DataStream with Scala | flink-streaming-scala_2.12 |
Table API | flink-table-api-java |
Table API with Scala | flink-table-api-scala_2.12 |
Table API + DataStream | flink-ta |