發(fā)簡信
IP屬地：浙江
-
算法系列-動態(tài)規(guī)劃(1)：初識動態(tài)規(guī)劃昨天崖堤，羅拉去面試回來耐床，垂頭喪氣密幔。顯然是面試不順利撩轰，我趕忙過去安慰胯甩。 經過詢問才知道堪嫂，羅拉面試掛在了動態(tài)規(guī)劃偎箫。 說到動態(tài)規(guī)劃皆串，八哥可就來精神了淹办，于...
-
算法系列-動態(tài)規(guī)劃(2)：切割鋼材問題
切割鋼材問題 接上回說到恶复，斐波那契數列是動態(tài)規(guī)劃最簡單應用，但動態(tài)規(guī)劃卻不是為了用來算那數列寂玲。 當時留了個尾巴塔插，就是切割鋼材的問題拓哟。 不同長度的...
-
ExceptionInChainedOperatorException：flink寫hbase對于null數據導致數據導致出現(xiàn)異常
使用的flink版本：1.9.1 異常描述 需求： 從kafka讀取一條數據流 經過filter初次篩選符合要求的數據 然后通過map進行一次條...
-
flink自定義窗口分配器 周糜烹、月關于分配器介紹內容來自官網 窗口分配的概念 窗口分配程序（Window Assigners）定義如何將元素分配給窗口。通過window(...)...
-
二叉樹的遍歷實現(xiàn)遞歸與非遞歸本文實現(xiàn)了二叉樹的深度遍歷算法，分為遞歸與非遞歸 遞歸的實現(xiàn)非常簡單茸炒，基本上沒啥難度 非遞歸的實現(xiàn)需要根據遍歷的順序愕乎，將遞歸轉換成循環(huán) 代碼中的...
-
flink 自定義觸發(fā)器 定時或達到數量觸發(fā)flink 觸發(fā)器 觸發(fā)器確定窗口(由窗口分配程序形成)何時準備由窗口函數處理感论。每個WindowAssigner都帶有一個默認觸發(fā)器。如果默認觸...
-
hbase-spark bulk load(二)概述 之前寫過spark批量導入Hbase的案例：Spark、BulkLoad Hbase囊陡、單列芳绩、多列撞反，實現(xiàn)了多列的操作妥色。整個過程涉及到排序、分...
-
Flink 1.9 FlinkKafkaProducer 使用 EXACTLY_ONCE 錯誤記錄
使用flink FlinkKafkaProducer 往kafka寫入數據的時候要求使用EXACTLY_ONCE語義本以為本以為按照官網寫一個就...
-
flink idea運行錯誤記錄
最近學習flink的時候寫了最簡單的一個demo,但是在測試的時候出現(xiàn)問題：org.apache.flink.util.FlinkExcepti...