自学内容网 自学内容网

Flink 开发工程应加载哪些依赖

在我们要开发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

原文地址:https://blog.csdn.net/chanyue123/article/details/143740323

免责声明:本站文章内容转载自网络资源,如本站内容侵犯了原著者的合法权益,可联系本站删除。更多内容请关注自学内容网(zxcms.com)!