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