發(fā)簡(jiǎn)信
IP屬地：青海
最近在項(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ù)庫(kù)來(lái)說(shuō)，比較小眾，即使接觸過(guò)一段時(shí)間flink后，還是會(huì)很好奇flink為啥要選擇rocksdb來(lái)做狀態(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來(lái)合并兩個(gè)參數(shù)生成一個(gè)新的值，這個(gè)新的值同時(shí)也可以再下一次reduce操作中跟新的參數(shù)的...
在flink的ProcessFunction中，我們可以注冊(cè)定時(shí)器設(shè)定延遲多長(zhǎng)時(shí)間后執(zhí)行某類操作，例如像這種：context.timerServ...