flink sql目前開發(fā)的方式包括純sql的開發(fā)，可以運(yùn)行在zeppelin上，也可以采用代碼進(jìn)行開發(fā)，打包成jar運(yùn)行，代碼開發(fā)的話每次都要新建工程，會(huì)有一些重復(fù)性的工作...
發(fā)簡(jiǎn)信
IP屬地：北京
-
Flink SQL實(shí)戰(zhàn)演練之腳手架開發(fā) -
flink - operator - KeyedStream - KeyedProcessFunction
描述 數(shù)據(jù)在KeyBy后對(duì)key按hash結(jié)果進(jìn)入對(duì)應(yīng)的KeyedProcessFunction subtask 同個(gè)key的數(shù)據(jù)的所有數(shù)據(jù)都會(huì)進(jìn)入同一個(gè)KeyedProce...
-
mac安裝Redis可視化工具-Redis Desktop ManagerRedis是一個(gè)超精簡(jiǎn)的基于內(nèi)存的鍵值對(duì)數(shù)據(jù)庫(kù)(key-value)，一般對(duì)并發(fā)有一定要求的應(yīng)用都用其儲(chǔ)存session，乃至整個(gè)數(shù)據(jù)庫(kù)。不過它公自帶一個(gè)最小化的命令行式的數(shù)...
-
Flink 使用之 CDC 自定義 DeserializationSchema
Flink 使用介紹相關(guān)文檔目錄 Flink 使用介紹相關(guān)文檔目錄[http://www.itdecent.cn/p/74f1990d047c] 背景 本篇接Flink 使...
-
Flink系列 - 實(shí)時(shí)數(shù)倉(cāng)之FlinkCDC實(shí)現(xiàn)動(dòng)態(tài)分流實(shí)戰(zhàn)（十）??自從Flink出了FlinkCDC之后，我們對(duì)數(shù)據(jù)庫(kù)日志的采集就變得方便了許多了，除去了MaxWell、Cannel、OGG等第三方組件的繁瑣配置，目前實(shí)現(xiàn)CDC有兩種方...
-
如何寫好項(xiàng)目方案設(shè)計(jì)文檔
事實(shí)上，撰寫項(xiàng)目規(guī)劃和設(shè)計(jì)文檔，最重要的不是文檔的模版和格式，而是里面的具體內(nèi)容，它往往需要結(jié)合實(shí)際客觀環(huán)境因素來綜合考慮，平衡取舍，是一個(gè)需要充分腦力活動(dòng)的工作。盡管如此，...
-
Storm，Spark，F(xiàn)link對(duì)比一、容錯(cuò)性（Fault Tolerance） spark依賴checkpoint機(jī)制來進(jìn)行容錯(cuò)，只要batch執(zhí)行到doCheckpoint操作前掛了，那么該batch就會(huì)被...
-
JAVA日志框架適配/沖突解決方案你是否遇到過配置了logback，啟動(dòng)時(shí)卻提示log4j錯(cuò)誤的情況？像下面這樣： 你是否遇到過SLF4J的這種報(bào)錯(cuò)？ 日志框架的沖突 上面的這些問題，基本都是由于多套日志框架...
-
高性能的Java日志框架log4j2Logback 算是 Java 里一個(gè)老牌的日志框架，從 2006 年開始第一個(gè)版本，迭代至今也十幾年了。不過 Logback 最近一個(gè)穩(wěn)定版本還停留在 2017 年，好幾年...
-
xx頭條開源了(純H5項(xiàng)目基于HBuilderX 、MUI、H5+)xx頭條開源了(純Swift項(xiàng)目)http://www.itdecent.cn/p/3228bfa3be7d 之兄弟篇 【xx頭條開源了(純H5項(xiàng)目)】 商業(yè)用途聯(lián)系lig...
-
Flink 優(yōu)化及問題問題排查 看反壓：背壓高的下游oprator就是瓶頸 關(guān)注checkpoint時(shí)長(zhǎng)checkpoint時(shí)長(zhǎng)一定程度影響系統(tǒng)吞吐 看核心指標(biāo)延遲指標(biāo)、吞吐等 資源使用率 常見問...
-
什么是可轉(zhuǎn)債打新？最近A股上漲，可轉(zhuǎn)債打新的收益也開始提升上來了，所以今天就給小伙伴們介紹下什么是可轉(zhuǎn)債打新~ 首先，我們來看下啥是可轉(zhuǎn)債。 可轉(zhuǎn)債的全稱是可轉(zhuǎn)換公司債券。在目前國(guó)內(nèi)市場(chǎng)，可轉(zhuǎn)...
-
?? 90后 ? 碩士畢業(yè)于 華中科技大學(xué)<br>?? 公眾號(hào) CodeSheep 作者<br>?? IT咨詢請(qǐng)公眾號(hào)私信<br>?? 自學(xué)編程之路↓↓↓<br><a href="https://links.jianshu.com/go?to=https%3A%2F%2Fgithub.com%2Fhansonwang99%2FJavaCollection" target="_blank">https://github.com/hansonwang99/JavaCollection</a>
-
??
技術(shù)人員需要“巴結(jié)”領(lǐng)導(dǎo)嗎？
面試的時(shí)候面試官經(jīng)常會(huì)問:(1)你們的用戶量是多少，項(xiàng)目的QPS是多少，TPS是多少，接口的數(shù)據(jù)量大概有多大；(2)生產(chǎn)線上的部署情況是否了解，怎么做的前后分離，如何做的集群...
-
這個(gè)需要你去定義你的schema了，然后利用一些其它手段
Logstash解析嵌套Json
由于我們的埋點(diǎn)日志是嵌套json類型，要想最終所有字段展開來統(tǒng)計(jì)分析就必須把嵌套json展開。 日志格式如下： 最開始Logstash的配置文件如下： 按照以上配置文件運(yùn)行L...
-
方案二親測(cè)可行，感謝博主
Mac系統(tǒng)HiDPI問題
我用mac就是因?yàn)槿思液每?，還好用。再不濟(jì)我會(huì)選擇Linux，因?yàn)槿思液糜枚乙膊怀蟆?** 重要的事情說3遍，連接Macbook和顯示器的線纜一定是DP口的。**** 重要...
-
@沙曉強(qiáng) 雖然ehcache是分布式框架，但是這篇文章介紹時(shí)還只是單機(jī)模式，所以沒有介紹分布式使用。
Java分布式緩存框架Ehcache 使用(一)
在開發(fā)中大型Java軟件項(xiàng)目時(shí)，對(duì)于頻繁讀寫數(shù)據(jù)庫(kù)的操作，為了減輕數(shù)據(jù)庫(kù)的壓力，我們常常會(huì)用到緩存。因?yàn)閿?shù)據(jù)庫(kù)連接是非?！鞍嘿F”的資源，因此我們需要增加一個(gè)抽象層來解決，緩存...
-
