最近在項(xiàng)目中用到了flink異步io模式去查詢r(jià)edis耻陕，相比于之前的同步訪問模式袍睡，性能提升了好幾倍，感嘆異步io模式的強(qiáng)大继阻，趁著這段時(shí)間有空好...

flink寫入kafka默認(rèn)采用的分區(qū)策略的代碼實(shí)現(xiàn)在FlinkFixedPartitioner這個(gè)類中，并不是我們理解的輪盤轉(zhuǎn)方式寫入下游分區(qū)...

rocksdb相對(duì)于mysql等數(shù)據(jù)庫來說逗旁，比較小眾立宜，即使接觸過一段時(shí)間flink后，還是會(huì)很好奇flink為啥要選擇rocksdb來做狀態(tài)存儲(chǔ)...

flink的窗口時(shí)間屬性TimeCharacteristic分為三種：ProcessingTime萎河，IngestionTime荔泳，EventTim...

flink中的ProcessWindowFunction經(jīng)常用在窗口觸發(fā)后對(duì)結(jié)果的數(shù)據(jù)的迭代處理以及獲得窗口的開始時(shí)間和截止時(shí)間等操作。它可以結(jié)...

flink為了提高執(zhí)行效率虐杯，會(huì)將部分算子進(jìn)行合并玛歌，合并后組成operator chain,這樣整個(gè)operator chain作為一個(gè)JobVe...

在flink中我們經(jīng)常會(huì)用到ReduceFunction來合并兩個(gè)參數(shù)生成一個(gè)新的值，這個(gè)新的值同時(shí)也可以再下一次reduce操作中跟新的參數(shù)的...

在flink的ProcessFunction中擎椰，我們可以注冊(cè)定時(shí)器設(shè)定延遲多長時(shí)間后執(zhí)行某類操作支子，例如像這種：context.timerServ...