Flink Table API & SQL 基本操作

Posted @SmartSi

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink Table API & SQL 基本操作相关的知识,希望对你有一定的参考价值。

Flink 版本:1.13.5

本文主要展示了 Table API 和 SQL 程序的常见结构,如何创建注册 Table,查询 Table,以及如何输出 Table。

1. Table API & SQL 程序结构

在 Flink 中,Table API 和 SQL 可以看作联结在一起的一套 API,这套 API 的核心概念是一个可以用作 Query 输入和输出的表 Table。在我们程序中,输入数据可以定义成一张表,然后对这张表进行查询得到一张新的表,最后还可以定义一张用于输出的表,负责将处理结果写入到外部系统。

我们可以看到,程序的整体处理流程与 DataStream API 非常相似,也可以分为读取数据源(Source)、转换(Transform)、输出数据(Sink)三部分。只不过这里的输入输出操作不需要额外定义,只需要将用于输入和输出的表 Table 定义出来,然后进行转换查询就可以了。

SQL 程序基本架构如下:

// 创建执行环境 TableEnvironment
EnvironmentSettings settings = EnvironmentSettings
        .newInstance

以上是关于Flink Table API & SQL 基本操作的主要内容,如果未能解决你的问题,请参考以下文章

2021年大数据Flink(三十):Flink ​​​​​​​Table API & SQL 介绍

Flink Table API & SQL Planner 演变

18-flink-1.10.1-Table API & Flink SQL

Flink Table API & SQL Planner 演变

Flink SQL - 2.Table API & SQL 概述与常规 API

Flink SQL - 1.Table API && Sql 入门 Demo