背景：近期由于跨機房數(shù)據(jù)同步問題，準備調(diào)研使用redis替換memcache墨礁，在調(diào)研過程中發(fā)現(xiàn)棘手的問題朦前，原有的memcache提供大量批量獲取操作(mget)操作，程序...
發(fā)簡信
IP屬地：重慶
-
redis cluster mget 引發(fā)的討論 -
Es7.x使用RestHighLevelClient進行增刪改和批量操作引入依賴 初始化RestHighLevelClient和BulkProcessor對象 增刪改操作3.1 數(shù)據(jù)準備3.2 單條數(shù)據(jù)異步插入3.3 單條數(shù)據(jù)同步插入3.4 批量...
-
Elastic job doAsfterJobExecutedAtLastCompleted多次執(zhí)行以及完成超時 源碼解析
主要涉及到兩個類 AbstractDistributeOnceElasticJobListener 媚值， 以及guaranteeService關(guān)鍵點還是在afterJobEx...
-
領(lǐng)域驅(qū)動設(shè)計DDD和CQRS落地前言 這篇文章假設(shè)你已經(jīng)初步了解過領(lǐng)域驅(qū)動設(shè)計(DDD)的基本概念(聚合根馍盟、實體、值對象梆奈、領(lǐng)域服務、領(lǐng)域事件称开、資源庫亩钟、限界上下文等)以及CQRS的設(shè)計，本文會將重點放在如何落...
-
剖析G1（Garbage First）歡迎關(guān)注筆者的公眾號：【阿飛的博客】鳖轰，首發(fā)都在這里Ｇ逅帧！蕴侣！ Java從JDK7U9開始支持G1（正式發(fā)布）焰轻，所以，如果要使用G1的話昆雀，你的Java版本應該是JDK7U9或者更新...
-
flink并行度與kafa分區(qū)(partition)設(shè)置flink并行度與kafa分區(qū)(partition)設(shè)置 flink Connector-kafka //TODO文章 connector系統(tǒng)文章辱志，等待編寫 原理 采用取模運...
-
談談Flink DataStream API中的三種雙流join操作前言 本文是基礎(chǔ)中的基礎(chǔ)，看官可以放心食用狞膘。 在數(shù)據(jù)庫中的靜態(tài)表上做OLAP分析時揩懒，兩表join是非常常見的操作。同理挽封，在流式處理作業(yè)中已球，有時也需要在兩條流上做join以獲得...
-
為什么列式存儲廣泛應用于OLAP領(lǐng)域？前言 233醬工作中開始接觸Presto等大數(shù)據(jù)分析場景下的內(nèi)容辅愿，列式存儲屬于OLAP中重要的一環(huán)智亮。這周主要花時間搜索閱讀網(wǎng)上的相關(guān)資料，發(fā)現(xiàn)一眾大數(shù)據(jù)点待、數(shù)據(jù)庫開發(fā)等大佬們的...
-
三色標記法與讀寫屏障前言 本文主要介紹了三色標記法的基本思路阔蛉、多標導致的浮動垃圾、漏標的處理方案（讀寫屏障）等亦鳞。 1. 垃圾回收的簡單回顧 關(guān)于垃圾回收算法馍忽，基本就是那么幾種：標記-清除棒坏、標記-...
