当前位置: 首页 > article >正文

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

http://www.kler.cn/a/392910.html

相关文章:

  • SpringBoot参数注解
  • 建筑施工特种作业人员安全生产知识试题
  • 【设计模式】行为型模式(二):策略模式、命令模式
  • 微服务(二)
  • 力扣104 : 二叉树最大深度
  • 【MySQL】MySQL函数之JSON_EXTRACT
  • JavaScript逆向爬虫教程-------基础篇之JavaScript密码学以及CryptoJS各种常用算法的实现
  • 英语中从句和复合句简单介绍
  • 老旧城区供水管网改造优先等级分析
  • stm32学习之路——八种GPIO口工作模式
  • el-form el-table 前端排序+校验+行编辑
  • LLMs之VDB:Elasticsearch的简介、安装和使用方法、案例应用之详细攻略
  • 服务器显卡和桌面pc显卡有什么不同
  • C++builder中的人工智能(17):神经网络中的自我规则非单调(Mish)激活函数
  • sklearn.datasets中make_classification函数
  • 3216. 交换后字典序最小的字符串
  • 单词反转和数组去重,附经典面试题一份
  • C/C++内存管理 | new的机制 | 重载自己的operator new
  • Mysql:使用binlog的一些常用技巧
  • TreeSet是什么
  • 分享一些Kafka集群优化的最佳实践?
  • DeepSpeed:PyTorch优化库,使模型分布式训练能高效使用内存和更快速
  • flink+kafka 如何保证精准一次
  • Java 中的字符输入流详解
  • IOS开发之AR问题汇总
  • web安全漏洞之命令注入