在flink流处理过程中,我们经常会遇到事件处理,例如双十一的时候,经过flink流处理的实时统计数据大盘,例如在业务系统的在线流风控系统等等业务场景,这时候我们一般会在flink中去读取流然后做我们想要操作的业务规...

作者 Rae 发布的文章
热文Flink流处理系列(七)使用flink的CEP复杂事件,实现用户登录的风控预警
这篇文章我们继续开启Flink流处理的实战环节,这篇文章我们利用Flink的CEP复杂事件来实现用户登录的风控预警。首先简要的介绍下CEP,CEP可以看做是flink中专门用于处理复杂事件的规则触发器,他的执行流程是...
数据仓库中如何对表分区进行度量设计?
在做数据仓库的时候,我们经常会涉及到对表进行分区,这些分区策略有:按照用户进行分区,这里主要是hash分区 按照每日一个分区,这里主要是时间分区 按照每周一个分区,这里主要是时间分区 按照每月一个分区,这里主要是时间...
热文配置frp windows客户端开机启动详细教程
上一篇文章《使用Frp映射本地电脑3389端口的安装教程》我们介绍了frp windows客户端的安装,在里面启动的时候我们是使用命令行启动的,但是试想一下,如果我们把命令行关闭了,或者重启了电脑,是不是就无法连接了...
热文使用Frp映射本地电脑3389端口的安装教程
上一篇文章《Frp服务端安装教程》我们把frp的服务端安装完成了,这篇文章我们演示下做本地3389端口的映射,这样子使用我的ipad输入云服务器的ip+端口后就可以连接我本地电脑了。一、首先下载frp客户端本地电脑是...
热文Frp服务端安装教程
最近周末需要出远门一趟,但是由于自己还有很多工作需要处理,因此需要使用到电脑。但是这次又不想把笔记本背上,由于本人有一个ipad,自带触控笔和键盘,因此想着出门的话,带个ipad即可,然后远程连接家里的电脑处理工作即...
Redis缓存雪崩的解决方案
上一篇文章《Redis缓存击穿的解决方案》我们介绍了缓存击穿的解决方案,这篇文章我们来介绍下缓存雪崩的解决方案。什么是缓存雪崩缓存雪崩指缓存中大量数据的失效时间集中在某一个时间段,导致在这个时间段内缓存失效并额外请求...
Redis缓存击穿的解决方案
上一篇文章《Redis缓存穿透的解决方案》我们介绍了缓存穿透的解决方案,这篇文章我们介绍缓存击穿的解决方案。什么是缓存击穿?缓存击穿指的是在一些高并发访问下,一个热点数据从缓存中不存在,每次请求都要直接查询数据库,从...
Redis缓存穿透的解决方案
在java开发过程中redis几乎是我们项目开发的标配,所以我们会经常涉及到利用redis进行开发。那么在redis开发过程中,我们经常会遇到缓存穿透的问题。这篇文章我们就来给大家介绍下缓存穿透的解决方案。首先说说什...
热文微服务实战spring cloud alibaba(十九)代码混淆
大家应该还记得,我们的代码一般编写好了之后,直接mvn install打成jar包之后就放到生产环境去使用了。但是想象一下,这个打包的jar包里面的class是可以完全的被反编译成完整的源码的,如果是ToB或者ToG...
热文DBAPI低代码平台添加redis缓存插件
上一篇文章《推荐一个低代码的后端开发平台-DBAPI》我们介绍了低代码平台DBAPI的简单使用。由于是演示环境,因此在演示的时候我们使用的是docker安装部署,在真实的环境中,建议使用安装包的方式进行部署,这样子可...
热文推荐一个低代码的后端开发平台-DBAPI
偶然间在网上看到一个后端的低代码开发平台-DBAPI。这里可以直接在页面上编写sql,编写完毕之后直接可以在线发布接口,这样子前端就可以直接开发了。非常方便。个人认为比较适合一些做数据分析方面的系统开发,也就是里面没...
热文Doris基础学习系列(三十六)Multi-Catalog 功能
在doris1.2版本开始,新提供了一种Multi-Catalog 功能,他的主要含义就是无缝对接外部异构的数据源,用户无需把数据导入到doris中,即可使用doris来创建一个Catalog,然后通过Catalog...
在前面的文章我们主要介绍了flink多数据源的时间窗口,然后对数据进行计算,但是试想一下,真实的生产环境中我们经常多数据源都是乱序的,所以此时我们多个数据源拿过来进行join的时候,由于数据处理的延迟,会导致如下情况...
使用Minikube快速的搭建一个本地的Kubernetes环境
在前面我们介绍了使用kuboard来搭建kubernetes环境,这种在生产上实用性非常高,但是在内部的测试环境上,一般我们不会涉及到那么奢侈,因此这里我们习惯性使用minikube来快速搭建一个本地或者测试环境的k...