發(fā)簡(jiǎn)信
IP屬地：廣東
-
Flink SQL在線調(diào)試功能的實(shí)現(xiàn)
Flink SQL在線調(diào)試功能能夠幫助用戶數(shù)據(jù)探索與邏輯校驗(yàn)，調(diào)試功能要求如下： 為了滿足上述要求，我們開發(fā)了基于redis的調(diào)試插件，用該插件...
-
Flink SQL多字段的維表關(guān)聯(lián)查詢-flink-connector-redis
Flink SQL經(jīng)常需要關(guān)聯(lián)維表，使用redis作為維表存儲(chǔ)介質(zhì)能獲得較快的響應(yīng)速度，大多情況維表有多個(gè)字段,寫入與維表查詢時(shí)只能使用conc...
-
flink catalog 之 flink-catalog-in-jdbc
開發(fā)思路 運(yùn)行環(huán)境全面升級(jí)到j(luò)dk11后，原基于hive catalog的flink catlog不能再使用，原因是現(xiàn)在hive所有版本都不支持...
-
flink維表查詢r(jià)edis之flink-connector-redis
插件名稱：flink-connector-redis 插件地址：https://github.com/jeff-zou/flink-connec...
-
mybatis insert后返回主鍵ID實(shí)現(xiàn)原理及源碼分析
引子： mybatis這類ORM在往數(shù)據(jù)庫insert對(duì)象后，會(huì)順帶將數(shù)據(jù)庫中的自增主鍵值賦值給對(duì)象的id,這個(gè)功能給我們的開發(fā)帶來了很多方便，...
-
W-TinyLFU源碼分析（Caffeine）
Caffeine使用一個(gè)ConcurrencyHashMap來保存所有數(shù)據(jù)，那它的過期淘汰策略采用的什么的方式與數(shù)據(jù)結(jié)構(gòu)呢?其中寫過期是使用wr...
-
flink1.12 sql向redis實(shí)時(shí)寫數(shù)據(jù)
插件名稱：flink-connector-redis 插件地址：https://github.com/jeff-zou/flink-connec...
-
go協(xié)程學(xué)習(xí)筆記協(xié)程本質(zhì)： go協(xié)程本質(zhì)上還是用線程來運(yùn)行代碼，只是在多線程上增加了調(diào)度器，通過調(diào)度器讓每一個(gè)線程可以執(zhí)行多個(gè)協(xié)程。 實(shí)現(xiàn)原理： go協(xié)程使用G...
-
FLINK基于SQL向redis更新多維度狀態(tài)（多字段）
在實(shí)時(shí)計(jì)算平臺(tái)接入業(yè)務(wù)過程中，經(jīng)常遇到這樣一個(gè)問題： 第一個(gè)任務(wù)獲得的最新狀態(tài)需要提供給后續(xù)一個(gè)或者多個(gè)任務(wù)使用。解決這個(gè)問題有很多方法，將狀態(tài)...