flink开发需要用到的依赖

时间: 2023-05-25 08:00:49 浏览: 291
Flink 开发需要用到的依赖包括但不限于: 1. Flink Core:Flink 核心库,包含了 Flink 的核心 API 和实现。 2. Flink Streaming:Flink 流处理库,提供了支持无界数据流处理的 API。 3. Flink Table:Flink 表格库,提供了 SQL 和 Table API 进行结构化数据处理的 API。 4. Flink SQL Client:Flink SQL 客户端,提供了使用 SQL 编写 Flink 作业的方式。 5. Flink Connectors:Flink 连接器库,提供了和其他系统交互的接口,例如 Kafka、Hadoop 等。 6. Flink Gelly:Flink 图计算库,提供了在 Flink 上执行图计算的 API。 7. Flink ML:Flink 机器学习库,提供了在 Flink 上进行机器学习的 API。 8. Flink CEP:Flink 复杂事件处理库,提供了支持复杂事件流的处理 API。 这些依赖可以通过 Maven 或 Gradle 等构建工具进行引入。同时,还需要根据实际需求添加其他依赖,例如数据库驱动、日志库等。
相关问题

idea 运行 Flink 1.12 需要那些依赖

在 IDEA 中运行 Flink 1.12 的项目,需要添加以下依赖: ```xml <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.12.0</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.12</artifactId> <version>1.12.0</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients_2.12</artifactId> <version>1.12.0</version> </dependency> ``` 其中,`flink-java` 是 Flink 的核心依赖,`flink-streaming-java_2.12` 是 Flink 流处理的依赖,`flink-clients_2.12` 是 Flink 的客户端依赖,可以用来提交 Flink 作业。 此外,如果您需要使用 Flink 的连接器(例如 Kafka、Elasticsearch等),还需要添加对应的连接器依赖。例如: ```xml <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-kafka_2.12</artifactId> <version>1.12.0</version> </dependency> ``` 这是 Flink 的 Kafka 连接器依赖,用于在 Flink 中读取和写入 Kafka 数据。 希望这些能够帮到您!

flink1.16sql项目依赖

Flink 1.16 SQL 项目的依赖可以在 Maven 中心库中找到。以下是一些常用的依赖: - Flink SQL 客户端依赖: ```xml <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-sql-client_2.12</artifactId> <version>1.16.0</version> </dependency> ``` - Flink SQL 运行时依赖: ```xml <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-table-api-java-bridge_2.12</artifactId> <version>1.16.0</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-table-planner_2.12</artifactId> <version>1.16.0</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-table-runtime-blink_2.12</artifactId> <version>1.16.0</version> </dependency> ``` - Flink 核心依赖: ```xml <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-core</artifactId> <version>1.16.0</version> </dependency> ``` 你也可以在 Flink 的官网上找到更多的依赖信息。

相关推荐

最新推荐

《剑指大数据——Flink学习精要(Java版)》(最终修订版).pdf

《剑指大数据——Flink学习精要(Java版)》(最终修订版).pdf

Flink +hudi+presto 流程图.docx

Flink +hudi+presto 流程图.docx 自己实现后画的一个流程图,便于理解

Flink实用教程_预览版_v1.pdf

最新Flink教程,基于Flink 1.13.2。书中所有示例和案例代码均为双语。这是预览版。 目录 第1 章Flink 架构与集群安装..............................................................................................

大数据之flink教程-TableAPI和SQL.pdf

1.2 需要引入的依赖 2 1.3 两种 planner(old & blink)的区别 4 第二章 API 调用 5 2.1 基本程序结构 5 2.2 创建表环境 5 2.3 在 Catalog 中注册表 7 2.3.1 表(Table)的概念 7 2.3.2 连接到文件系统(Csv 格式) ...

Flink基础讲义.docx

第一章 Flink简介【了解】 1 1.1. Flink的引入 1 1.2. 什么是Flink 4 1.3. Flink流处理特性 4 1.4. Flink基石 5 1.5. 批处理与流处理 6 第二章 Flink架构体系 8 ...第十一章 flink-SQL开发 277 第十二章 总结 292

stc12c5a60s2 例程

stc12c5a60s2 单片机的所有功能的实例,包括SPI、AD、串口、UCOS-II操作系统的应用。

管理建模和仿真的文件

管理Boualem Benatallah引用此版本:布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学,1996年。法语。NNT:电话:00345357HAL ID:电话:00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆,用于存放和传播科学研究论文,无论它们是否被公开。论文可以来自法国或国外的教学和研究机构,也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire

【迁移学习在车牌识别中的应用优势与局限】: 讨论迁移学习在车牌识别中的应用优势和局限

![【迁移学习在车牌识别中的应用优势与局限】: 讨论迁移学习在车牌识别中的应用优势和局限](https://img-blog.csdnimg.cn/direct/916e743fde554bcaaaf13800d2f0ac25.png) # 1. 介绍迁移学习在车牌识别中的背景 在当今人工智能技术迅速发展的时代,迁移学习作为一种强大的技术手段,在车牌识别领域展现出了巨大的潜力和优势。通过迁移学习,我们能够将在一个领域中学习到的知识和模型迁移到另一个相关领域,从而减少对大量标注数据的需求,提高模型训练效率,加快模型收敛速度。这种方法不仅能够增强模型的泛化能力,提升识别的准确率,还能有效应对数据

margin-top: 50%;

margin-top: 50%; 是一种CSS样式代码,用于设置元素的上边距(即与上方元素或父级元素之间的距离)为其父元素高度的50%。 这意味着元素的上边距将等于其父元素高度的50%。例如,如果父元素的高度为100px,则该元素的上边距将为50px。 请注意,这个值只在父元素具有明确的高度(非auto)时才有效。如果父元素的高度是auto,则无法确定元素的上边距。 希望这个解释对你有帮助!如果你还有其他问题,请随时提问。

Android通过全局变量传递数据

在Activity之间数据传递中还有一种比较实用的方式 就是全局对象 实用J2EE的读者来说都知道Java Web的四个作用域 这四个作用域从小到大分别是Page Request Session和Application 其中Application域在应用程序的任何地方都可以使用和访问 除非是Web服务器停止 Android中的全局对象非常类似于Java Web中的Application域 除非是Android应用程序清除内存 否则全局对象将一直可以访问 1 定义一个类继承Application public class MyApp extends Application 2 在AndroidMainfest xml中加入全局变量 android:name &quot; MyApp&quot; 3 在传数据类中获取全局变量Application对象并设置数据 myApp MyApp getApplication ; myApp setName &quot;jack&quot; ; 修改之后的名称 4 在收数据类中接收Application对象 myApp MyApp getApplication ;">在Activity之间数据传递中还有一种比较实用的方式 就是全局对象 实用J2EE的读者来说都知道Java Web的四个作用域 这四个作用域从小到大分别是Page Request Session和Application 其中Application域在应用程序的任何地方都可以使用和 [更多]