0


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

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

标签: flink 大数据

本文转载自: https://blog.csdn.net/chanyue123/article/details/143740323
版权归原作者 sf_www 所有, 如有侵权,请联系我们删除。

“Flink 开发工程应加载哪些依赖”的评论:

还没有评论