Demo：基于 Flink SQL 构建流式应用
Flink 1.10.0 于近期刚发布，释放了许多令人激动的新特性。尤其是 Flink SQL 模块，发展速度非常快，因此本文特意从实践的角度出发，带领大家一起探索使用 Flink SQL 如何快速构建流式应用。 本文将基于 Kafka, MySQL, Elasticsearch, Kibana ...
原文：Flink1.11 SQL Demo: 构建一个端到端的流式应用
本文将基于 Kafka, MySQL, Elasticsearch, Kibana，使用 Flink SQL 构建一个电商用户行为的实时分析应用。本文所有的实战演练都将在 Flink SQL CLI 上执行，全程只涉及 SQL 纯文本，无需一行 Java Scala 代码，无需安装 IDE。本实战演练的最终效果图： 准备 一台装有 Docker 的 Linux 或 MacOS 计算机。 使用 Do ...
2020-07-23 11:50 11 1578 推荐指数：
相关推荐
使用flink Table &Sql api来构建批量和流式应用(3)Flink Sql 使用
从flink的官方文档，我们知道flink的编程模型分为四层，sql层是最高层的api，Table api是中间层，DataStream/DataSet Api 是核心，stateful Streaming process层是底层实现。 其中， flink dataset ...
Flink1.11中的CDC Connectors操作实践
Flink1.11引入了CDC的connector，通过这种方式可以很方便地捕获变化的数据，大大简化了数据处理的流程。Flink1.11的CDC connector主要包括：MySQL CDC和Postgres CDC,同时对Kafka的Connector支持canal-json ...
Flink1.11 解决 No ExecutorFactory found to execute the application
在使用Flink1.11的时候写了个本地Test 运行的时候发现报错了，具体如下 查看Flink1.11 release文档发现 从Flink 1.11.0 开始flink-streaming-java不再依赖flink-client需要单独引用，那么增加相应依赖 ...
使用flink Table &Sql api来构建批量和流式应用(1)Table的基本概念
从flink的官方文档，我们知道flink的编程模型分为四层，sql层是最高层的api，Table api是中间层，DataStream/DataSet Api 是核心，stateful Streaming process层是底层实现。 其中， flink ...
使用flink Table &Sql api来构建批量和流式应用(2)Table API概述
从flink的官方文档，我们知道flink的编程模型分为四层，sql层是最高层的api，Table api是中间层，DataStream/DataSet Api 是核心，stateful Streaming process层是底层实现。 其中， flink dataset ...