文章 2023-12-26 来自:开发者社区

基于Flume+Kafka+Hbase+Flink+FineBI的实时综合案例(三)离线分析

08:离线分析:Hbase表设计及构建目标:掌握Hbase表的设计及创建表的实现路径step1:基础设计step2:Rowkey设计step3:分区设计step4:建表实施基础设计Namespace:MOMO_CHATTable:MOMO_MSGFamily:C1Qualifier:与数据中字段名保持一致Rowkey设计查询需求:根据发件人id + 收件人id + 消息日期 查询聊天记录发件人账....

基于Flume+Kafka+Hbase+Flink+FineBI的实时综合案例(三)离线分析
文章 2022-06-13 来自:开发者社区

【Flink】(十三)Flink CEP Library 使用案例分析

文章目录一、前言二、CEPTest三、Alert四、MonitoringEvent五、TemperatureEvent一、前言根据Flink CEP library来监控数据中心中每个机柜的温度。当在一定的时间内,如果有2个连续的Event中的温度超过设置的阈值时,就产生一条警告;一条警告也许还不是很坏的结果,但是如果我们在同一个机柜上连续看到2条这种警告,这种情况比较严重了。所以根据第一个警告....

文章 2018-02-08 来自:开发者社区

Flink SQL 功能解密系列 —— 流计算“撤回(Retraction)”案例分析

什么是retraction(撤回) 通俗讲retract就是传统数据里面的更新操作,也就是说retract是流式计算场景下对数据更新的处理 方式。 首先来看下流场景下的一个词频统计列子。 没有retract会导致最终结果不正确↑: retract发挥的作用 下面再分享两个双十一期间retract保证数据正确性的业务case: case1: 菜鸟物流订单统计 同一个订单的商品在运输过程中,因...

Flink SQL 功能解密系列 —— 流计算“撤回(Retraction)”案例分析
文章 2017-11-21 来自:开发者社区

Flink之CEP案例分析-网络攻击检测

上一篇我们介绍了Flink CEP的API,这一篇我们将以结合一个案例来练习使用CEP的API编写应用程序,以强化对API的理解。所选取的案例是对网络遭受的潜在攻击进行检测并给出告警。当下互联网安全形势仍然严峻,网络攻击屡见不鲜且花样众多,这里我们以DDOS(分布式拒绝服务攻击)产生的流入流量来作为遭受攻击的判断依据。 假定一家云服务提供商,有多个跨地区的数据中心,每个数据中心会定时向监控中心.....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注