Demo：基于 Flink SQL 构建流式应用
Flink 1.10.0 于近期刚发布，释放了许多令人激动的新特性。尤其是 Flink SQL 模块，发展速度非常快，因此本文特意从实践的角度出发，带领大家一起探索使用 Flink SQL 如何快速构建流式应用。 本文将基于 Kafka, MySQL, Elasticsearch, Kibana ...
原文：Flink系列之1.10版流式SQL应用
随着Flink . 的发布，对SQL的支持也非常强大。Flink 还提供了 MySql, Hive，ES, Kafka等连接器Connector，所以使用起来非常方便。 接下来咱们针对构建流式SQL应用文章的梗概如下： . 搭建流式SQL应用所需要的环境准备。 . 构建一个按每小时进行统计购买量的应用。 . 构建每天以 分钟的粒度进行统计应用。 . 构建按分类进行排行，取出想要的结果应用。 . ...
2020-03-15 16:05 0 4179 推荐指数：
相关推荐
Flink 1.10 SQL 写HBase
Hbase 也是我们很常用的数据存储组件，所以提前尝试下用SQL 写Hbase，中间也遇到一些坑，跟大家分享一下。 官网地址：https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table ...
Flink sql 流式去重
在大数据的处理过程中会出现很多汇总类指标的计算，比如计算当日的每个类目下的用户的订单信息，就需要按类目分组，对用户做去重。Flink sql 提供了 “去重” 功能，可以在流模式的任务中做去重操作。 官网文档 去重 官网链接： [去重](https://ci.apache.org ...
Flink 1.10 SQL 写ElasticSearch
官网对应页面：https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/connect.html#elasticsearch-connector Flink SQL ElasticSearch connector ...
Flink Batch SQL 1.10 实践
Flink作为流批统一的计算框架，在1.10中完成了大量batch相关的增强与改进。1.10可以说是第一个成熟的生产可用的Flink Batch SQL版本，它一扫之前Dataset的羸弱，从功能和性能上都有大幅改进，以下我从架构、外部系统集成、实践三个方面进行阐述。 架构 Stack ...
Flink 1.10 SQL 读写Kafka
最近因为疫情的原因，偷了好长时间的懒，现在终于开始继续看Flink 的SQL 了 ———————————————— 电脑上的Flink 项目早就升级到了 1.10了，最近还在看官网新的文档，趁着周末，体验一下新版本的SQL API（踩一下坑）。 直接从之前的 云邪大佬的Flink ...
使用flink Table &Sql api来构建批量和流式应用(3)Flink Sql 使用
从flink的官方文档，我们知道flink的编程模型分为四层，sql层是最高层的api，Table api是中间层，DataStream/DataSet Api 是核心，stateful Streaming process层是底层实现。 其中， flink dataset ...
Flink 1.10 SQL 自定义KafkaUpsertSink
在 Flink 1.10 中SQL正式生产，在尝试使用的时候，遇到了这样的问题： KafkaTableSink 的 'update-mode' 只支持 ‘append’，如下面这样： 看起来好像没问题，因为kafka 也只能往里面写数据，不能删数据 官网链接：https ...