Flink1.11 SQL Demo: 构建一个端到端的流式应用
本文将基于 Kafka, MySQL, Elasticsearch, Kibana，使用 Flink SQL 构建一个电商用户行为的实时分析应用。本文所有的实战演练都将在 Flink SQL CLI 上执行，全程只涉及 SQL 纯文本，无需一行 Java/Scala 代码，无需安装 IDE。本实战 ...
原文：Demo：基于 Flink SQL 构建流式应用
Flink . . 于近期刚发布，释放了许多令人激动的新特性。尤其是 Flink SQL 模块，发展速度非常快，因此本文特意从实践的角度出发，带领大家一起探索使用 Flink SQL 如何快速构建流式应用。 本文将基于 Kafka, MySQL, Elasticsearch, Kibana，使用 Flink SQL 构建一个电商用户行为的实时分析应用。本文所有的实战演练都将在 Flink SQL ...
2020-02-28 15:26 0 1635 推荐指数：
相关推荐
使用flink Table &Sql api来构建批量和流式应用(3)Flink Sql 使用
从flink的官方文档，我们知道flink的编程模型分为四层，sql层是最高层的api，Table api是中间层，DataStream/DataSet Api 是核心，stateful Streaming process层是底层实现。 其中， flink dataset ...
使用flink Table &Sql api来构建批量和流式应用(2)Table API概述
从flink的官方文档，我们知道flink的编程模型分为四层，sql层是最高层的api，Table api是中间层，DataStream/DataSet Api 是核心，stateful Streaming process层是底层实现。 其中， flink dataset ...
使用flink Table &Sql api来构建批量和流式应用(1)Table的基本概念
从flink的官方文档，我们知道flink的编程模型分为四层，sql层是最高层的api，Table api是中间层，DataStream/DataSet Api 是核心，stateful Streaming process层是底层实现。 其中， flink ...
Flink系列之1.10版流式SQL应用
随着Flink 1.10的发布，对SQL的支持也非常强大。Flink 还提供了 MySql, Hive，ES, Kafka等连接器Connector，所以使用起来非常方便。 接下来咱们针对构建流式SQL应用文章的梗概如下： 1. 搭建流式SQL应用所需要的环境准备。 2. ...
Flink sql 流式去重
在大数据的处理过程中会出现很多汇总类指标的计算，比如计算当日的每个类目下的用户的订单信息，就需要按类目分组，对用户做去重。Flink sql 提供了 “去重” 功能，可以在流模式的任务中做去重操作。 官网文档 去重 官网链接： [去重](https://ci.apache.org ...
构建流式应用—RxJS详解
讲之前先说一点哈，插入的图片，不能正常显示，图片一半被遮盖了，如果想看，鼠标右击然后图片地址，图片另存为去看。如果有知道怎么解决的，可以在下面给我评论，我会及时的修改。 好啦，开始： 目录 ...
Flink SQL 流式写数据到 Hive
Flink 1.11 版本对SQL的优化是很多的，其中最重要的一点就是 hive 功能的完善，不再只是作为持久化的 Catalog，而是可以用原生的 Flink SQL 流式的写数据到入 hive中 本文使用官网 “Streaming Writing” 案例 （https ...