Flink Table API 和 SQL之概述

Flink针对标准的流处理和批处理提供了两种相关的API，Table API和sql。TableAPI允许用户以一种很直观的方式进行select 、filter和join操作。Flink SQL支持基于 Apache Calcite实现的标准SQL。针对批处理和流处理可以提供相同的处理语义和结果。

Flink Table API、SQL接口和Flink的DataStream API、DataSet API是紧密联系在一起的。

使用步骤：

Flink的Table API和SQL是捆绑在flink-table依赖中的。所以，如果你的项目中想要使用Table API 和SQL的话，必须要添加下面依赖

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-table_2.11</artifactId>
  <version>1.6.1</version>
</dependency>

注意：针对Flink 的scala操作你还需要添加下面依赖

针对Flink的scala batch操作添加如下依赖

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-scala_2.11</artifactId>
  <version>1.6.1</version>
</dependency>

针对Flink的scala streaming操作添加如下依赖：

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-streaming-scala_2.11</artifactId>
  <version>1.6.1</version>
</dependency>

注意：为了避免用户的类加载器被垃圾回收器回收，官方不建议把flink-table这个jar包和业务代码包含在一块。

推荐把Flink-table的依赖拷贝到Flink的lib目录下。

获取更多大数据资料，视频以及技术交流请加群：

QQ群号1：295505811

QQ群号2：54902210

QQ群号3：555684318

版权声明：本文来源CSDN，感谢博主原创文章，遵循 CC 4.0 by-sa 版权协议，转载请附上原文出处链接和本声明。
原文链接：https://blog.csdn.net/xu470438000/article/details/84390665
站方申明：本站部分内容来自社区用户分享，若涉及侵权，请联系站方删除。

发表于 2020-03-07 18:21:29
阅读 ( 1470 )
分类：

Flink Table API 和 SQL之概述

你可能感兴趣的文章

精选的优质文章

0 条评论

官方社群

GO教程

推荐文章

猜你喜欢

随便看看