Flink的 Window 操作 Window是無(wú)限數(shù)據(jù)流處理的核心敬肚，Window將一個(gè)無(wú)限的stream拆分成有限大小的”buckets”桶，我們可以在這些桶上做計(jì)算操作焕刮。...
發(fā)簡(jiǎn)信
IP屬地：山東
-
Flink 的Window 操作
-
Apache Flink源碼解析 （五）DataStream API概述 這篇文章是但不僅僅是官方文檔的中文翻譯，還有里面每一個(gè)方法對(duì)應(yīng)的Transformation和運(yùn)行時(shí)對(duì)Task的影響。 Prerequisites 關(guān)于算子想說(shuō)的有很多...
-
Flink WaterMark 詳解背景 實(shí)時(shí)計(jì)算中鼓寺，數(shù)據(jù)時(shí)間比較敏感。有eventTime和processTime區(qū)分勋磕，一般來(lái)說(shuō)eventTime是從原始的消息中提取過(guò)來(lái)的妈候，processTime是Flink...
-
flink Savepoint 和 Checkpoint 使用checkpoint應(yīng)用定時(shí)觸發(fā)，用于保存狀態(tài)挂滓，會(huì)過(guò)期內(nèi)部應(yīng)用失敗重啟的時(shí)候使用苦银，特點(diǎn)是作業(yè)容錯(cuò)自動(dòng)恢復(fù)，輕量，自動(dòng)周期管理 savepoint用戶手動(dòng)執(zhí)行幔虏，是指向Check...
-
高效壓縮位圖RoaringBitmap的原理與應(yīng)用目錄 位圖法簡(jiǎn)述 RoaringBitmap的思路 Container原理ArrayContainerBitmapContainerRunContainer時(shí)空分析Conta...
-
小米消息推送服務(wù)接入流程考慮到接下來(lái)的一份工作可能會(huì)從事消息推送服務(wù)的開(kāi)發(fā)纺念，于是為了能夠更快的熟悉業(yè)務(wù)，花了點(diǎn)時(shí)間研究小米的消息推送服務(wù)的接入想括。文章的主要內(nèi)容都是來(lái)自小米推送服務(wù)介紹陷谱，以及會(huì)對(duì)部分內(nèi)...
-
Redis 5 集群選舉原理分析Redis 5 集群選舉原理分析 Redis系統(tǒng)介紹： Redis的基礎(chǔ)介紹與安裝使用步驟：http://www.reibang.com/p/2a23257af57bRed...
-
IO多路復(fù)用的三種機(jī)制Select，Poll主胧，Epoll
I/O多路復(fù)用（multiplexing）的本質(zhì)是通過(guò)一種機(jī)制（系統(tǒng)內(nèi)核緩沖I/O數(shù)據(jù)）叭首，讓單個(gè)進(jìn)程可以監(jiān)視多個(gè)文件描述符，一旦某個(gè)描述符就緒（一般是讀就緒或?qū)懢途w）踪栋，能夠通...
-
-
k := k* ibigm 改成 k = k* ibigm 測(cè)試了下也是沒(méi)問(wèn)題的
MurmurHash go實(shí)現(xiàn)
MurmurHash介紹MurmurHash是一種非加密型哈希函數(shù)夷都，和其它流行哈希函數(shù)相比眷唉，對(duì)于規(guī)律性較強(qiáng)的key隨機(jī)分布特性表現(xiàn)更良好，在很多開(kāi)源的軟件項(xiàng)目（Redis囤官，M...
-
談?wù)勏蘖魉惴ǖ膸追N實(shí)現(xiàn)占小狼[http://www.reibang.com/users/90ab66c248e6/latest_articles]冬阳，轉(zhuǎn)載請(qǐng)注明原創(chuàng)出處，謝謝党饮！ 保障服務(wù)穩(wěn)定的三大...
-
nginx 基本入門(mén)(至今為止見(jiàn)過(guò)最好的 nginx 入門(mén)文章肝陪，沒(méi)有之一。)
本文作者：ivweb villainthr 原文出處：ivweb 社區(qū)未經(jīng)同意刑顺，禁止轉(zhuǎn)載本文屬于翻譯文章氯窍，原文鏈接為nginx Beginner’s Guide。是至今為止見(jiàn)...
-
Linux高可用之Keepalived簡(jiǎn)介 Keepalived是基于vrrp協(xié)議的一款高可用軟件蹲堂。Keepailived有一臺(tái)主服務(wù)器和多臺(tái)備份服務(wù)器狼讨，在主服務(wù)器和備份服務(wù)器上面部署相同的服務(wù)配置，使用一個(gè)虛擬...
-
JVM所有參數(shù)一覽
注意：所有參數(shù)基于JDK7和JDK8提绕饩骸（java -XX:+PrintFlagsFinal -version）政供，且每個(gè)參數(shù)的值可以通過(guò)命令jinfo -flag JVMPa...
-
kafka 0.10.1一些使用經(jīng)驗(yàn)概述 最近公司對(duì)老版本的kafka做升級(jí)，我們的集群很小朽基，就三臺(tái)機(jī)器布隔。主要用來(lái)爬取數(shù)據(jù)實(shí)時(shí)任務(wù)傳輸用的。老版本用的0.8版本的踩晶，這個(gè)版本zookeeper的依賴還是比較大执泰，每...
-
堆外內(nèi)存的回收機(jī)制分析占小狼轉(zhuǎn)載請(qǐng)注明原創(chuàng)出處，謝謝渡蜻！ 堆外內(nèi)存 JVM啟動(dòng)時(shí)分配的內(nèi)存，稱為堆內(nèi)存，與之相對(duì)的茸苇，在代碼中還可以使用堆外內(nèi)存排苍，比如Netty，廣泛使用了堆外內(nèi)存学密，但是這部分的內(nèi)存并...
-
Spring Cloud Ribbon設(shè)計(jì)原理Ribbon 是netflix 公司開(kāi)源的基于客戶端的負(fù)載均衡組件淘衙，是Spring Cloud大家庭中非常重要的一個(gè)模塊；Ribbon應(yīng)該也是整個(gè)大家庭中相對(duì)而言比較復(fù)雜的模...
-
mysql索引篇之覆蓋索引、聯(lián)合索引哭靖、索引下推文章是學(xué)習(xí)了林曉斌老師在極客時(shí)間的《mysql實(shí)戰(zhàn)45講》后具垫，根據(jù)自己的理解整理而成的。 覆蓋索引 在之前《mysql索引初識(shí)》這篇文章中提到過(guò)试幽，mysql的innodb引擎...
