Flink学习31:TableAPI&SQL之注册表-创新互联

让客户满意是我们工作的目标,不断超越客户的期望值来自于我们对这个行业的热爱。我们立志把好的技术通过有效、简单的方式提供给客户,将通过不懈努力成为客户在信息化领域值得信任、有价值的长期合作伙伴,公司提供的服务项目有:主机域名网站空间、营销软件、网站建设、淳安网站维护、网站推广。table API

tableAPI & flink SQL

flink SQL是最上层的封装,封装了流处理的DataStream API 和 批处理的DataSet API。

但是DataStream API 、DataSet API、table API、flink SQL 这几层并没有分到不同层中,所以应用程序可以同时使用这几层。

Table API & SQL 介绍

执行原理

ps:

Flink为Table & SQL API提供了两种planner,分别为Blink planner和old planner

flink-table-planner-blink_hzp666的博客-博客

org.apache.flinkflink-scala_2.121.14.4org.apache.flinkflink-streaming-scala_2.121.14.4org.apache.flinkflink-table-api-java-bridge_2.121.14.4org.apache.flinkflink-table-planner_2.121.14.4org.apache.flinkflink-connector-kafka_2.121.14.4org.apache.flinkflink-statebackend-rocksdb_2.121.14.4

注册表

flink中表可以分为 视图和表

注册表的2种方式,

1.直接创建

2.使用表连接器

连接器分为下边几种

文件系统连接器

JDBC连接器


你是否还在寻找稳定的海外服务器提供商?创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源,准确流量调度确保服务器高可用性,企业级服务器适合批量采购,新人活动首月15元起,快前往官网查看详情吧


本文名称:Flink学习31:TableAPI&SQL之注册表-创新互联
本文URL:http://pwwzsj.com/article/ddicpg.html