參考1參考2參考3參考4參考5 推送： 服務(wù)器給客戶端發(fā)送消息開發(fā)者通過第三方推送服務(wù)提供商將信息直接下發(fā)給需要的設(shè)備，第三方推送服務(wù)提供商與設(shè)備建立一條長連接通道，并且將消...
發(fā)簡信
IP屬地：北京
-
IM+推送+心跳機(jī)制 -
Flink1.11升級(jí)填坑
背景 現(xiàn)有集群版本是Flink 1.10.1，想要升級(jí)到社區(qū)最新的版本Flink 1.11.1. 踩坑過程 No hostname could be resolved for...
-
Kettle下載和安裝Kettle簡介：Kettle 是 PDI 以前的名稱，PDI 的全稱是Pentaho Data Integeration，Kettle 本意是水壺的意思，表達(dá)了數(shù)據(jù)流的含義...
-
python中defaultdict用法詳解
認(rèn)識(shí)defaultdict： 當(dāng)我使用普通的字典時(shí)，用法一般是dict={},添加元素的只需要dict[element] =value即，調(diào)用的時(shí)候也是如此，dict[ele...
-
Flink實(shí)戰(zhàn)—Flink SQL在Batch場(chǎng)景的Demo最近工作會(huì)用到Flink SQL，周末學(xué)習(xí)了一下，寫個(gè)demo做記錄，全部代碼請(qǐng)參考Github. 基于的Flink版本是1.9.1，使用的是java8開發(fā)。 本例是Flin...
-
Parquet 實(shí)踐和基本原理生成一個(gè)parquet文件 下載 編譯 運(yùn)行 準(zhǔn)備csv文件 生成parquet文件 可見目錄下多了一個(gè)sample.parquet文件。這里沒有指定avsc格式的schem...
-
使用Flink完成流數(shù)據(jù)統(tǒng)計(jì)一、統(tǒng)計(jì)流程 所有流計(jì)算統(tǒng)計(jì)的流程都是：1、接入數(shù)據(jù)源2、進(jìn)行多次數(shù)據(jù)轉(zhuǎn)換操作(過濾、拆分、聚合計(jì)算等)3、計(jì)算結(jié)果的存儲(chǔ)其中數(shù)據(jù)源可以是多個(gè)、數(shù)據(jù)轉(zhuǎn)換的節(jié)點(diǎn)處理完數(shù)據(jù)可以發(fā)...
-
聊聊flink如何兼容StormTopology
序 本文主要研究一下flink如何兼容StormTopology 實(shí)例 這里使用FlinkLocalCluster.getLocalCluster()來創(chuàng)建或獲取FlinkL...
