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