在flink 应用程序中还有一个比较大的模块,也就是Table API & SQL模块,这个模块对于我们在实际的开发过程中来说,使用频率非常高,特别是配合Dinky 使用可以在实际的开发中极大的增加我们的开发效率。
这里的Table API 和SQL 在Flink中其实介绍的都是一个东西,也就是把数据进行结构化,然后当作是数据库表一样的操作。唯一不同的是Table API是相当于使用java语言的函数来对数据进行操作,使用SQL的话就只需要编写相关的sql语句就可以操作数据。
在flink中Table API和SQL两种API是集成在一起的,我们在编写flink的job的时候,可以随意在Table API和sql之间进行函数切换。使用非常方便。
在接下来的系列里面,我们将以table api&sql 来进行实际的案例讲解。
备注:
1、在使用table api或者sql进行编程的时候记得引入如下的maven依赖:
<dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-table-api-java</artifactId> <version>${version}</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-table-api-java-bridge</artifactId> <version>${version}</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-table-planner_2.12</artifactId> <version>${version}</version> </dependency>
还没有评论,来说两句吧...