一、背景 事實(shí)表通常存儲(chǔ)在kafka中，維表通常存儲(chǔ)在外部設(shè)備中(比如MySQL，HBase)。對(duì)于每條流式數(shù)據(jù)，可以關(guān)聯(lián)一個(gè)外部維表數(shù)據(jù)源，為實(shí)時(shí)計(jì)算提供數(shù)據(jù)關(guān)聯(lián)查詢。維表...
發(fā)簡信
IP屬地：山東
-
Flink 維表Join/雙流Join 方法總結(jié) -
Hudi On Flink一、背景 傳統(tǒng)數(shù)倉分為離線和實(shí)時(shí)兩個(gè)部分 離線部分屬于業(yè)務(wù)驅(qū)動(dòng)，固定的計(jì)算邏輯，通過定時(shí)調(diào)度，最后產(chǎn)出報(bào)表； 實(shí)時(shí)部分屬于需求驅(qū)動(dòng)，需要靈活開發(fā)。 傳統(tǒng)架構(gòu)整體還是以離線為主...
-
-
偷情真的那么刺激嗎？
今天早上十一點(diǎn)的時(shí)候，到常去的理發(fā)店理發(fā)，到的時(shí)候，只有老板娘一個(gè)人坐在店里，見我來了，老板娘才打電話讓老板趕緊回來做生意。 我連著早上來幾天，老板不是不開門，就是...
-
Flink流處理API一、Environment 1.getExecutionEnvironment 創(chuàng)建一個(gè)執(zhí)行環(huán)境，表示當(dāng)前執(zhí)行程序的上下文。 如果程序是獨(dú)立調(diào)用的，則此方法返回本地執(zhí)行環(huán)境；...
-
-
