技术总舵
如果我没有在装逼,那么就是在去装逼的路上!

Tagged: Apache Flink

Flink进阶教程之SideOutputSplit分流

版本说明: 环境: Windiws Scala: 2.11.8 Flink :1.10.1 大部分的DataStream API的算子的输出是单一输出,也就是某种数据类型的流。 除了split算子,可以将一条流分成多条流,这些流的数据类型也都相同。 proces…

Flink 反压 浅入浅出

前言 微信搜【Java3y】关注这个朴实无华的男人,点赞关注是对我最大的支持! 文本已收录至我的GitHub:https://github.com/ZhongFuCheng3y/3y,有300多篇原创文章,最近在连载面试和项目系列! 最近一直在迁移Fli…

ClickHouse实战留存、路径、漏斗、session

什么是留存,比如在20200701这天操作了“点击banner”的用户有100个,这部分用户在20200702这天操作了“点击app签到”的有20个,那么对于分析时间是20200701,且“点击banner”的用户在次日“点击app签到”的留存…

网骗欺诈?网络裸奔?都是因为 HTTP?

先跟大家讲个故事,我初恋是在初中时谈的,我的后桌的后桌。那个时候没有手机这类的沟通工具,上课交流有三宝,脚踢屁股、笔戳后背以及传纸条,当然我只能是那个屁股和后背,还不是能让初恋踢到的后背。 但是说实…

基于云原生的大数据实时分析方案实践

1 方案介绍 大数据处理技术现今已广泛应用于各个行业,为业务解决海量存储和海量分析的需求。但数据量的爆发式增长,对数据处理能力提出了更大的挑战,同时对时效性也提出了更高的要求。实时分析已成为企业大数据…

百亿级实时计算系统性能优化–—Elasticsearch篇

导语 | 随着业务的发展,系统日益复杂,功能愈发强大,用户数量级不断增多,设备cpu、io、带宽、成本逐渐增加,当发展到某个量级时,这些因素会导致系统变得臃肿不堪,服务质量难以保障,系统稳定性变差,耗费相当…

5分钟从零构建第一个 Apache Flink 应用

在本文中,我们将从零开始,教您如何构建第一个Apache Flink (以下简称Flink)应用程序。 开发环境准备 Flink 可以运行在 Linux, Max OS X, 或者是 Windows 上。为了开发 Flink 应用程序,在本地机器上需要有 Ja…

基于flink sql构建报警系统的若干技术点

1)选择滑动窗口 滑动窗口会导致一个时间点的数据会分布到多个window里来,其它跟滚动窗口没区别 2)滑动数据重新汇聚 计算源是单个时间窗口内预汇聚的数据,不适用于滑动窗口的计算值,比如前面单个窗口计算出来p…