Flink SQL 1.11 on Zeppelin 平台化实践
简介： 鉴于有很多企业都无法配备专门的团队来解决 Flink SQL 平台化的问题，那么到底有没有一个开源的、开箱即用的、功能相对完善的组件呢？答案就是本文的主角——Apache Zeppelin。 作者：LittleMagic 大数据领域 SQL 化开发的风潮方兴未艾（所谓 ...
原文：Flink SQL 1.11 on Zeppelin 平台化实践
作者：LittleMagic 大数据领域 SQL 化开发的风潮方兴未艾 所谓 Everybody knows SQL ，Flink 自然也不能 免俗 。 Flink SQL 是 Flink 系统内部最高级别的 API，也是流批一体思想的集大成者。 用户可以通过简单明了的 SQL 语句像查表一样执行流任务或批任务，屏蔽了底层 DataStream DataSet API 的复杂细节，降低了使用门槛。 ...
2020-11-27 15:57 0 416 推荐指数：
相关推荐
Flink SQL 1.11新功能详解：Hive 数仓实时化 & Flink SQL + CDC 实践
问题导读1.Flink 1.11 有哪些新功能？ 2.如何使用 flink-cdc-connectors 捕获 MySQL 和 Postgres 的数据变更? 3.怎样利用 Flink SQL 做多流 join 后实时同步到 Elasticsearch 中 ...
Flink 1.11 Table & SQL深度解读
1. kafka table DDL 动态table,后者定义覆盖前者, 一次创建多次使用 2.clone table 完整继承、或者覆盖OPTION 3.性 ...
唯品会：在 Flink 容器化与平台化上的建设实践
简介： 唯品会 Flink 的容器化实践应用，Flink SQL 平台化建设，以及在实时数仓和实验平台上的应用案例。 转自dbaplus社群公众号作者：王康，唯品会数据平台高级开发工程师 自 2017 年起，为保障内部业务在平时和大促期间的平稳运行，唯品会就开始基 ...
Flink1.11中的CDC Connectors操作实践
Flink1.11引入了CDC的connector，通过这种方式可以很方便地捕获变化的数据，大大简化了数据处理的流程。Flink1.11的CDC connector主要包括：MySQL CDC和Postgres CDC,同时对Kafka的Connector支持canal-json ...
Flink1.11中的CDC Connectors操作实践
Flink1.11引入了CDC的connector，通过这种方式可以很方便地捕获变化的数据，大大简化了数据处理的流程。Flink1.11的CDC connector主要包括：MySQL CDC和Postgres CDC,同时对Kafka的Connector支持 ...