
本文說明如何在已有的cdh集群上添加flink服務纳击。分為如下幾步進行說明: 1.環(huán)境說明 2.flink-parcel的制作 3.cm添加flink-parcel 4.cm上...
安裝好cdh后在cloudera-manager管理界面上并沒有kafka服務,在CDH官網(wǎng)中關于Kafka的安裝和升級中已經(jīng)說到攻臀,在CDH中焕数,Kafka作為一個分布式的...
由于使用apache hadoop進行部署,部署步驟繁多刨啸,管理運維成本較高堡赔,于是使用Cloudera Manager進行部署、管理hadoop集群设联,能夠加快部署善已,減少運維...
前面的文章介紹了當達到一定的條件后memstore會flush生成hfile,隨著hfile文件逐漸增多离例,查詢可能需要更多的IO操作雕拼,為了合并這些hfile文件從而衍生出了c...
個人覺得debug運行代碼是理解代碼最為有效的方式,所以今天說一下在window上使用idea進行調試運行hbase源碼(使用的是cdh版本的hbase)粘招。下面將從環(huán)境配...
hbase region 切分是hbases水平擴展一個重要因素啥寇,將一個region切分為兩個小region,并將切分后的region放在不同的節(jié)點上洒扎,以達到將負載進行均...
memstore是hbase中一個非常重要的組件辑甜,對于hbase的讀寫操作的性能起到舉足輕重的作用,下面講從memstore概述袍冷、memstore flush觸發(fā)條件磷醋、m...
雖說hbase適合寫多讀少,但是hbase的讀性能也是非常強悍的胡诗,hbase有如此好的讀性能其中少不了BlockCache邓线。BlockCache是regionserver...
眾所周知hbase是一個寫性能非常優(yōu)越的NOSQL,今天從源碼中分析一下put操作到了region中是如何進行處理的煌恢。 region中處理put請求的大致流程如下圖所...
前文介紹了使用CountDownLatch來實現(xiàn)線程間同步骇陈,但是CountDownLatch的計數(shù)器是一次性的,當計數(shù)器值減到0之后再調用await或countdown方...
說到線程同步第一個想到的一定是Thread類的join方法瑰抵,當需要等待一個線程執(zhí)行結束之后再接著執(zhí)行本線程接下去的邏輯你雌,join經(jīng)常會在這種場景下被使用,但是join方法...
ScheduledThreadPoolExecutor是一個可以指定一定延遲時間后或者定時進行任務調度執(zhí)行的線程池二汛,繼承于ThreadPoolExecutor婿崭,關于Thre...
今天來說一說線程池ThreadPoolExecutor拨拓,線程池主要解決兩個問題:一是當執(zhí)行大量異步任務時線程池能夠提供較好的性能。在不使用線程池時氓栈,每當需要執(zhí)行異步任務時...
前面介紹了5種并發(fā)隊列的原理渣磷,ConcurrentLinkedQueue、LinkedBlockingQueue授瘦、ArrayBlockingQueue幸海、PriorityB...
今天來說一說DelayQueue,DelayQueue并發(fā)隊列是一個無界阻塞延遲隊列奥务,隊列中的每個元素都有一個過期時間,當從隊列獲取元素時袜硫,只有過期元素才會出隊列氯葬,不允許...
PriorityBlockingQueue是帶優(yōu)先級的無界阻塞隊列,每次出隊都返回優(yōu)先級最高或最低的元素婉陷。其內部使用平衡二叉樹堆實現(xiàn)的帚称,所以遍歷隊列元素不能保證有序性。默...
前面一文介紹了有界鏈表阻塞隊列LinkedBlockingQueue秽澳,今天來說一說有界數(shù)組阻塞隊列ArrayBlockingQueue闯睹。 ArrayBlockingQu...
前面的文章介紹了使用CAS算法實現(xiàn)的非阻塞有界隊列ConcurrentLinkedQueue(詳情點這里),今天介紹另一個并發(fā)隊列LinkedBlockingQueue担神。...