發(fā)簡信
IP屬地：廣東
-
算法系列-動(dòng)態(tài)規(guī)劃(1)：初識(shí)動(dòng)態(tài)規(guī)劃昨天，羅拉去面試回來，垂頭喪氣。顯然是面試不順利，我趕忙過去安慰。 經(jīng)過詢問才知道，羅拉面試掛在了動(dòng)態(tài)規(guī)劃。 說到動(dòng)態(tài)規(guī)劃，八哥可就來精神了，于...
-
算法系列-動(dòng)態(tài)規(guī)劃(2)：切割鋼材問題
切割鋼材問題 接上回說到，斐波那契數(shù)列是動(dòng)態(tài)規(guī)劃最簡單應(yīng)用，但動(dòng)態(tài)規(guī)劃卻不是為了用來算那數(shù)列。 當(dāng)時(shí)留了個(gè)尾巴，就是切割鋼材的問題。 不同長度的...
-
ExceptionInChainedOperatorException：flink寫hbase對(duì)于null數(shù)據(jù)導(dǎo)致數(shù)據(jù)導(dǎo)致出現(xiàn)異常
使用的flink版本：1.9.1 異常描述 需求： 從kafka讀取一條數(shù)據(jù)流 經(jīng)過filter初次篩選符合要求的數(shù)據(jù) 然后通過map進(jìn)行一次條...
-
flink自定義窗口分配器 周、月關(guān)于分配器介紹內(nèi)容來自官網(wǎng) 窗口分配的概念 窗口分配程序（Window Assigners）定義如何將元素分配給窗口。通過window(...)...
-
二叉樹的遍歷實(shí)現(xiàn)遞歸與非遞歸本文實(shí)現(xiàn)了二叉樹的深度遍歷算法，分為遞歸與非遞歸 遞歸的實(shí)現(xiàn)非常簡單，基本上沒啥難度 非遞歸的實(shí)現(xiàn)需要根據(jù)遍歷的順序，將遞歸轉(zhuǎn)換成循環(huán) 代碼中的...
-
flink 自定義觸發(fā)器 定時(shí)或達(dá)到數(shù)量觸發(fā)flink 觸發(fā)器 觸發(fā)器確定窗口(由窗口分配程序形成)何時(shí)準(zhǔn)備由窗口函數(shù)處理。每個(gè)WindowAssigner都帶有一個(gè)默認(rèn)觸發(fā)器。如果默認(rèn)觸...
-
hbase-spark bulk load(二)概述 之前寫過spark批量導(dǎo)入Hbase的案例：Spark、BulkLoad Hbase、單列、多列，實(shí)現(xiàn)了多列的操作。整個(gè)過程涉及到排序、分...
-
Flink 1.9 FlinkKafkaProducer 使用 EXACTLY_ONCE 錯(cuò)誤記錄
使用flink FlinkKafkaProducer 往kafka寫入數(shù)據(jù)的時(shí)候要求使用EXACTLY_ONCE語義本以為本以為按照官網(wǎng)寫一個(gè)就...
-
flink idea運(yùn)行錯(cuò)誤記錄
最近學(xué)習(xí)flink的時(shí)候?qū)懥俗詈唵蔚囊粋€(gè)demo,但是在測(cè)試的時(shí)候出現(xiàn)問題：org.apache.flink.util.FlinkExcepti...