Flink Table API 和 SQL 需要引入的依赖

编程入门 行业动态 更新时间:2024-10-26 02:26:45

Flink <a href=https://www.elefans.com/category/jswz/34/1766340.html style=Table API 和 SQL 需要引入的依赖"/>

Flink Table API 和 SQL 需要引入的依赖

记下来后续使用

先把需要的依赖贴上:

<dependencies><dependency><groupId>org.apache.flink</groupId><artifactId>flink-table-api-scala-bridge_2.11</artifactId><version>${flink.version}</version></dependency><dependency><groupId>org.apache.flink</groupId><artifactId>flink-table-api-java-bridge_2.11</artifactId><version>${flink.version}</version></dependency><!-- flink执行计划,这是1.9版本之前的--><dependency><groupId>org.apache.flink</groupId><artifactId>flink-table-planner_2.11</artifactId><version>${flink.version}</version></dependency><!-- blink执行计划,1.11+默认的--><dependency><groupId>org.apache.flink</groupId><artifactId>flink-table-planner-blink_2.11</artifactId><version>${flink.version}</version></dependency><dependency><groupId>org.apache.flink</groupId><artifactId>flink-table-common</artifactId><version>${flink.version}</version></dependency><dependency><groupId>org.apache.flink</groupId><artifactId>flink-runtime-web_2.11</artifactId><version>${flink.version}</version></dependency>
</dependencies>

flink-table-common:这个包中主要是包含 Flink Planner 和 Blink Planner一些共用的代码。

flink-table-api-java:这部分是用户编程使用的 API,包含了大部分的 API。

flink-table-api-scala:这里只是非常薄的一层,仅和 Table API 的 Expression 和 DSL 相关。

两个 Planner:flink-table-planner 和 flink-table-planner-blink。

两个 Bridge:flink-table-api-scala-bridge 和 flink-table-api-java-bridge,

Flink Planner 和 Blink Planner 都会依赖于具体的 JavaAPI,也会依赖于具体的 Bridge,通过 Bridge 可以将 API 操作相应的转化为Scala 的 DataStream、DataSet,或者转化为 JAVA 的 DataStream 或者Data Set

原文链接:Flink Table API 和 SQL 需要引入的依赖详解

更多推荐

Flink Table API 和 SQL 需要引入的依赖

本文发布于:2023-12-06 03:33:25,感谢您对本站的认可!
本文链接:https://www.elefans.com/category/jswz/34/1666316.html
版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。
本文标签:Table   Flink   SQL   API

发布评论

评论列表 (有 0 条评论)
草根站长

>www.elefans.com

编程频道|电子爱好者 - 技术资讯及电子产品介绍!