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