Flink的 Window 操作 Window是无限数据流处理的核心,Window将一个无限的stream拆分成有限大小的”buckets”桶,我们可以在这些桶上做计算操作。...
Flink的 Window 操作 Window是无限数据流处理的核心,Window将一个无限的stream拆分成有限大小的”buckets”桶,我们可以在这些桶上做计算操作。...
概述 这篇文章是但不仅仅是官方文档的中文翻译,还有里面每一个方法对应的Transformation和运行时对Task的影响。 Prerequisites 关于算子想说的有很多...
背景 实时计算中,数据时间比较敏感。有eventTime和processTime区分,一般来说eventTime是从原始的消息中提取过来的,processTime是Flink...
checkpoint应用定时触发,用于保存状态,会过期内部应用失败重启的时候使用,特点是作业容错自动恢复,轻量,自动周期管理 savepoint用户手动执行,是指向Check...
目录 位图法简述 RoaringBitmap的思路 Container原理ArrayContainerBitmapContainerRunContainer时空分析Conta...
考虑到接下来的一份工作可能会从事消息推送服务的开发,于是为了能够更快的熟悉业务,花了点时间研究小米的消息推送服务的接入。文章的主要内容都是来自小米推送服务介绍,以及会对部分内...
Redis 5 集群选举原理分析 Redis系统介绍: Redis的基础介绍与安装使用步骤://www.greatytc.com/p/2a23257af57bRed...
I/O多路复用(multiplexing)的本质是通过一种机制(系统内核缓冲I/O数据),让单个进程可以监视多个文件描述符,一旦某个描述符就绪(一般是读就绪或写就绪),能够通...
1 rpc框架原理 rpc调用原理框架如图: 2 业内比较成熟的rpc框架 支持多语言的主要分为3类 -支持多语言的rpc框架,例如Google的grpc,facebook ...
k := k* ibigm 改成 k = k* ibigm 测试了下也是没问题的
MurmurHash go实现MurmurHash介绍MurmurHash是一种非加密型哈希函数,和其它流行哈希函数相比,对于规律性较强的key随机分布特性表现更良好,在很多开源的软件项目(Redis,M...
占小狼[//www.greatytc.com/users/90ab66c248e6/latest_articles],转载请注明原创出处,谢谢! 保障服务稳定的三大...
本文作者:ivweb villainthr 原文出处:ivweb 社区未经同意,禁止转载本文属于翻译文章,原文链接为nginx Beginner’s Guide。是至今为止见...
简介 Keepalived是基于vrrp协议的一款高可用软件。Keepailived有一台主服务器和多台备份服务器,在主服务器和备份服务器上面部署相同的服务配置,使用一个虚拟...
注意:所有参数基于JDK7和JDK8提取(java -XX:+PrintFlagsFinal -version),且每个参数的值可以通过命令jinfo -flag JVMPa...
概述 最近公司对老版本的kafka做升级,我们的集群很小,就三台机器。主要用来爬取数据实时任务传输用的。老版本用的0.8版本的,这个版本zookeeper的依赖还是比较大,每...
占小狼转载请注明原创出处,谢谢! 堆外内存 JVM启动时分配的内存,称为堆内存,与之相对的,在代码中还可以使用堆外内存,比如Netty,广泛使用了堆外内存,但是这部分的内存并...
Ribbon 是netflix 公司开源的基于客户端的负载均衡组件,是Spring Cloud大家庭中非常重要的一个模块;Ribbon应该也是整个大家庭中相对而言比较复杂的模...
文章是学习了林晓斌老师在极客时间的《mysql实战45讲》后,根据自己的理解整理而成的。 覆盖索引 在之前《mysql索引初识》这篇文章中提到过,mysql的innodb引擎...