發(fā)簡信
IP屬地：廣東
最近在項目中用到了flink異步io模式去查詢redis，相比于之前的同步訪問模式，性能提升了好幾倍，感嘆異步io模式的強大，趁著這段時間有空好...
flink寫入kafka默認采用的分區(qū)策略的代碼實現(xiàn)在FlinkFixedPartitioner這個類中，并不是我們理解的輪盤轉方式寫入下游分區(qū)...
rocksdb相對于mysql等數(shù)據(jù)庫來說，比較小眾，即使接觸過一段時間flink后，還是會很好奇flink為啥要選擇rocksdb來做狀態(tài)存儲...
flink的窗口時間屬性TimeCharacteristic分為三種：ProcessingTime，IngestionTime，EventTim...
flink中的ProcessWindowFunction經(jīng)常用在窗口觸發(fā)后對結果的數(shù)據(jù)的迭代處理以及獲得窗口的開始時間和截止時間等操作。它可以結...
flink為了提高執(zhí)行效率，會將部分算子進行合并，合并后組成operator chain,這樣整個operator chain作為一個JobVe...
在flink中我們經(jīng)常會用到ReduceFunction來合并兩個參數(shù)生成一個新的值，這個新的值同時也可以再下一次reduce操作中跟新的參數(shù)的...
在flink的ProcessFunction中，我們可以注冊定時器設定延遲多長時間后執(zhí)行某類操作，例如像這種：context.timerServ...